Package org.apache.storm.starter.trident
Class TridentMinMaxOfVehiclesTopology
java.lang.Object
org.apache.storm.starter.trident.TridentMinMaxOfVehiclesTopology
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 SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionstatic StormTopologyCreates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with valuesTridentMinMaxOfVehiclesTopology.VehicleandTridentMinMaxOfVehiclesTopology.Driverrespectively.static void
- 
Constructor Details- 
TridentMinMaxOfVehiclesTopologypublic TridentMinMaxOfVehiclesTopology()
 
- 
- 
Method Details- 
buildVehiclesTopologyCreates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with valuesTridentMinMaxOfVehiclesTopology.VehicleandTridentMinMaxOfVehiclesTopology.Driverrespectively.
- 
main- Throws:
- Exception
 
 
-