Interface | Description |
---|---|
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 | Description |
---|---|
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. |
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.