cascading.tuple.hadoop.collect
Class HadoopTupleCollectionFactory

java.lang.Object
  cascading.tuple.hadoop.collect.HadoopTupleCollectionFactory

All Implemented Interfaces:

CascadingFactory<org.apache.hadoop.mapred.JobConf,Collection<Tuple>>, TupleCollectionFactory<org.apache.hadoop.mapred.JobConf>

public class HadoopTupleCollectionFactory
extends Object
implements TupleCollectionFactory<org.apache.hadoop.mapred.JobConf>

Field Summary

Fields inherited from interface cascading.tuple.collect.TupleCollectionFactory

TUPLE_COLLECTION_FACTORY

Constructor Summary

HadoopTupleCollectionFactory()

Method Summary

Collection<Tuple>	create(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess) Method create will return a new instance of the type create by this factory.
void	initialize(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess) Method initialize will configure an initialize this factory instance.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HadoopTupleCollectionFactory

public HadoopTupleCollectionFactory()

Method Detail

initialize

public void initialize(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess)

Description copied from interface: CascadingFactory

Method initialize will configure an initialize this factory instance.

Specified by:

initialize in interface CascadingFactory<org.apache.hadoop.mapred.JobConf,Collection<Tuple>>

Parameters:

flowProcess - of type FlowProcess

create

public Collection<Tuple> create(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess)

Description copied from interface: CascadingFactory

Method create will return a new instance of the type create by this factory.

Specified by:

create in interface CascadingFactory<org.apache.hadoop.mapred.JobConf,Collection<Tuple>>

Parameters:

flowProcess - of type FlowProcess

Returns:

of type Instance