Package org.apache.flink.streaming.util

Class Summary

Class	Description
FiniteTestSource<T>	A stream source that: 1) emits a list of elements without allowing checkpoints, 2) then waits for two more checkpoints to complete, 3) then re-emits the same elements before 4) waiting for another two checkpoints and 5) exiting.
LatencyStats	The LatencyStats objects are used to track and report on the behavior of latencies across measurements.
StreamCollector	A simple utility for collecting all the elements in a DataStream.
TestStreamEnvironment	A StreamExecutionEnvironment that executes its jobs on MiniCluster.

Enum Summary

Enum	Description
LatencyStats.Granularity	Granularity for latency metrics.