|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |
Interface Summary | |
---|---|
Spillable | |
Spillable.SpillListener | |
Spillable.SpillStrategy | |
TupleCollectionFactory<Config> | Interface TupleCollectionFactory allows developers to plugin alternative implementations of a "tuple collection" used to back in memory "join" and "co-group" operations. |
TupleMapFactory<Config> | Interface TupleMapFactory allows developers to plugin alternative implementations of a "tuple map" used to back in memory "join" and "co-group" operations. |
Class Summary | |
---|---|
SpillableProps | Class SpillableProps is a fluent interface for building properties to be passed to a
FlowConnector before creating new Flow instances. |
SpillableTupleList | Class SpillableTupleList is a simple durable Collection that can spill its contents to disk when the
threshold is met. |
SpillableTupleMap | SpillableTupleMap is a HashMap that will allow for multiple values per key, and if the number of values for a given
key reach a specific threshold, they will be spilled to disk using a SpillableTupleList instance. |
|
|||||||||
PREV PACKAGE NEXT PACKAGE | FRAMES NO FRAMES |