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 trident Stream.

Constructor Summary

Constructors

Constructor	Description
TridentMinMaxOfVehiclesTopology()

Method Summary

Modifier and Type	Method	Description
static StormTopology	buildVehiclesTopology()	Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with values TridentMinMaxOfVehiclesTopology.Vehicle and TridentMinMaxOfVehiclesTopology.Driver respectively.
static void	main(String[] args)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

TridentMinMaxOfVehiclesTopology

public TridentMinMaxOfVehiclesTopology()

Method Details

buildVehiclesTopology

public static StormTopology buildVehiclesTopology()

Creates a topology which demonstrates min/max operations on tuples of stream which contain vehicle and driver fields with values TridentMinMaxOfVehiclesTopology.Vehicle and TridentMinMaxOfVehiclesTopology.Driver respectively.

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception