Class TridentMinMaxOfVehiclesTopology

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

public class TridentMinMaxOfVehiclesTopology extends Object
This class demonstrates different usages of * Stream.minBy(String, Comparator) * Stream.min(Comparator) * Stream.maxBy(String, Comparator) * Stream.max(Comparator) operations on trident Stream.
  • Constructor Details

    • TridentMinMaxOfVehiclesTopology

      public TridentMinMaxOfVehiclesTopology()
  • Method Details

    • 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 TridentMinMaxOfVehiclesTopology.Vehicle and TridentMinMaxOfVehiclesTopology.Driver respectively.
    • main

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