cascading.tuple.collect
Interface TupleCollectionFactory<Config>
- All Superinterfaces:
- CascadingFactory<Config,Collection<Tuple>>
public interface TupleCollectionFactory<Config>
- extends CascadingFactory<Config,Collection<Tuple>>
Interface TupleCollectionFactory allows developers to plugin alternative implementations of a "tuple collection"
used to back in memory "join" and "co-group" operations. Typically these implementations are
"spillable", in that to prevent using up all memory in the JVM, after some threshold is met or event
is triggered, values are persisted to disk.
The Collection
classes returned must take a Tuple
as a value.
If the Collection implementation implements the Spillable
interface, it will receive a Spillable.SpillListener
instance that calls back to the appropriate logging mechanism for the platform.
The class SpillableTupleList
may be used as a base class.
- See Also:
HadoopTupleCollectionFactory
,
SpillableTupleList
,
HadoopSpillableTupleList
,
TupleMapFactory
,
HadoopTupleMapFactory
TUPLE_COLLECTION_FACTORY
static final String TUPLE_COLLECTION_FACTORY
- See Also:
- Constant Field Values
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.