Class TridentMinMaxOfDevicesTopology

    • Constructor Detail

      • TridentMinMaxOfDevicesTopology

        public TridentMinMaxOfDevicesTopology()
    • Method Detail

      • buildDevicesTopology

        public static StormTopology buildDevicesTopology()
        Creates a topology with device-id and count (which are whole numbers) as tuple fields in a stream and it finally generates result stream based on min amd max with device-id and count values.
      • buildVehiclesTopology

        public static StormTopology buildVehiclesTopology()
        Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with values TridentMinMaxOfDevicesTopology.Vehicle and TridentMinMaxOfDevicesTopology.Driver respectively.