Package org.apache.storm.starter.trident
package org.apache.storm.starter.trident
-
ClassDescriptionA simple example that demonstrates the usage of
Stream.map(MapFunction)
andStream.flatMap(FlatMapFunction)
functions.This class demonstrates different usages of *Stream.minBy(String)
*Stream.maxBy(String)
operations on tridentStream
.This class demonstrates different usages of *Stream.minBy(String, Comparator)
*Stream.min(Comparator)
*Stream.maxBy(String, Comparator)
*Stream.max(Comparator)
operations on tridentStream
.Sample application of trident windowing which uses inmemory store for storing tuples in window.