Package org.apache.storm.starter.trident
package org.apache.storm.starter.trident
-
ClassesClassDescriptionA 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.