Package org.apache.storm.starter.trident
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 tridentStream.
-
-
Constructor Summary
Constructors Constructor Description TridentMinMaxOfVehiclesTopology()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static StormTopologybuildVehiclesTopology()Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with valuesTridentMinMaxOfVehiclesTopology.VehicleandTridentMinMaxOfVehiclesTopology.Driverrespectively.static voidmain(String[] args)
-
-
-
Method Detail
-
buildVehiclesTopology
public static StormTopology buildVehiclesTopology()
Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with valuesTridentMinMaxOfVehiclesTopology.VehicleandTridentMinMaxOfVehiclesTopology.Driverrespectively.
-
-