Package org.apache.storm.starter.trident
Class TridentMinMaxOfDevicesTopology
- java.lang.Object
-
- org.apache.storm.starter.trident.TridentMinMaxOfDevicesTopology
-
public class TridentMinMaxOfDevicesTopology extends Object
This class demonstrates different usages of *Stream.minBy(String)*Stream.maxBy(String)operations on tridentStream.
-
-
Constructor Summary
Constructors Constructor Description TridentMinMaxOfDevicesTopology()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static StormTopologybuildDevicesTopology()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 StormTopologybuildVehiclesTopology()Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with valuesTridentMinMaxOfDevicesTopology.VehicleandTridentMinMaxOfDevicesTopology.Driverrespectively.static voidmain(String[] args)
-
-
-
Method Detail
-
buildDevicesTopology
public static StormTopology 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
public static StormTopology buildVehiclesTopology()
Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with valuesTridentMinMaxOfDevicesTopology.VehicleandTridentMinMaxOfDevicesTopology.Driverrespectively.
-
-