Package org.apache.storm.starter.trident
Class TridentMinMaxOfDevicesTopology
java.lang.Object
org.apache.storm.starter.trident.TridentMinMaxOfDevicesTopology
This class demonstrates different usages of
*
Stream.minBy(String)
* Stream.maxBy(String)
operations on trident Stream
.-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionstatic StormTopology
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.static StormTopology
Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with valuesTridentMinMaxOfDevicesTopology.Vehicle
andTridentMinMaxOfDevicesTopology.Driver
respectively.static void
-
Constructor Details
-
TridentMinMaxOfDevicesTopology
public TridentMinMaxOfDevicesTopology()
-
-
Method Details
-
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
Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with valuesTridentMinMaxOfDevicesTopology.Vehicle
andTridentMinMaxOfDevicesTopology.Driver
respectively. -
main
- Throws:
Exception
-