public class HadoopTupleCollectionFactory extends java.lang.Object implements TupleCollectionFactory<Configuration>
TUPLE_COLLECTION_FACTORY
Constructor and Description |
---|
HadoopTupleCollectionFactory() |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<Tuple> |
create(FlowProcess<? extends Configuration> flowProcess) |
void |
initialize(FlowProcess<? extends Configuration> flowProcess) |
public HadoopTupleCollectionFactory()
public void initialize(FlowProcess<? extends Configuration> flowProcess)
initialize
in interface CascadingFactory<Configuration,java.util.Collection<Tuple>>
public java.util.Collection<Tuple> create(FlowProcess<? extends Configuration> flowProcess)
create
in interface CascadingFactory<Configuration,java.util.Collection<Tuple>>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.