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 Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic StormTopology
Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with valuesTridentMinMaxOfVehiclesTopology.Vehicle
andTridentMinMaxOfVehiclesTopology.Driver
respectively.static void
-
Constructor Details
-
TridentMinMaxOfVehiclesTopology
public TridentMinMaxOfVehiclesTopology()
-
-
Method Details
-
buildVehiclesTopology
Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with valuesTridentMinMaxOfVehiclesTopology.Vehicle
andTridentMinMaxOfVehiclesTopology.Driver
respectively. -
main
- Throws:
Exception
-