Package cascading.flow.stream

Interface Summary

CloseWindow
Collapsing	Collapsing marks a Duct as collapsing start/complete events from multiple incoming paths
ElementDuct
Mapping
OpenWindow
Reducing<Group,Result>

Class Summary

AggregatorEveryStage
BufferEveryWindow
CloseReducingDuct<Group,Incoming,Outgoing>
Duct<Incoming,Outgoing>
DuctGraph
DuctGraph.Ordinal
EachStage
ElementStage<Incoming,Outgoing>
EveryStage<Incoming>
FilterEachStage
Fork<Incoming,Outgoing>
FunctionEachStage
Gate<Incoming,Outgoing>
GroupAssertionEveryStage
Grouping<Group,ItemIterator extends Iterator>
JoinStage
MemoryCoGroupClosure
MemoryCoGroupGate
MemoryHashJoinGate
MemorySpliceGate
MergeStage
OpenDuct<Incoming,Outgoing>
OpenReducingDuct<Incoming,Outgoing>
OperatorStage<Incoming>
SinkStage
SourceStage
SparseTupleComparator
SpliceGate
Stage<Incoming,Outgoing>
StepStreamGraph
StreamGraph	Class StreamGraph is the operation pipeline used during processing.
TrapHandler
ValueAssertionEachStage

Enum Summary

SpliceGate.Role

Exception Summary

DuctException
TrapException	TrapException is a pass through exception allowing trap io failures to propagate past upstream traps.