Package cascading.tuple.collect

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.
 



Copyright © 2007-2014 Concurrent, Inc. All Rights Reserved.