Class TridentMinMaxOfDevicesTopology

java.lang.Object
org.apache.storm.starter.trident.TridentMinMaxOfDevicesTopology

public class TridentMinMaxOfDevicesTopology extends Object
This class demonstrates different usages of * Stream.minBy(String) * Stream.maxBy(String) operations on trident Stream.
  • Constructor Details

    • TridentMinMaxOfDevicesTopology

      public TridentMinMaxOfDevicesTopology()
  • Method Details

    • 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.
    • main

      public static void main(String[] args) throws Exception
      Throws:
      Exception