cascading.tuple.hadoop.collect
Class HadoopTupleMapFactory

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

All Implemented Interfaces:

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

public class HadoopTupleMapFactory
extends Object
implements TupleMapFactory<org.apache.hadoop.mapred.JobConf>

Field Summary

Fields inherited from interface cascading.tuple.collect.TupleMapFactory

TUPLE_MAP_FACTORY

Constructor Summary

HadoopTupleMapFactory()

Method Summary

Map<Tuple,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

HadoopTupleMapFactory

public HadoopTupleMapFactory()

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,Map<Tuple,Collection<Tuple>>>

Parameters:

flowProcess - of type FlowProcess

create

public Map<Tuple,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,Map<Tuple,Collection<Tuple>>>

Parameters:

flowProcess - of type FlowProcess

Returns:

of type Instance