cascading.tuple.hadoop.collect
Class HadoopTupleMapFactory

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

All Implemented Interfaces:

cascading.provider.CascadingFactory<JobConf,Map<cascading.tuple.Tuple,Collection<cascading.tuple.Tuple>>>, cascading.tuple.collect.TupleMapFactory<JobConf>

public class HadoopTupleMapFactory
extends Object
implements cascading.tuple.collect.TupleMapFactory<JobConf>

Field Summary

Fields inherited from interface cascading.tuple.collect.TupleMapFactory

TUPLE_MAP_FACTORY

Constructor Summary

HadoopTupleMapFactory()

Method Summary

Map<cascading.tuple.Tuple,Collection<cascading.tuple.Tuple>>	create(cascading.flow.FlowProcess<JobConf> flowProcess)
void	initialize(cascading.flow.FlowProcess<JobConf> flowProcess)

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(cascading.flow.FlowProcess<JobConf> flowProcess)

Specified by:

initialize in interface cascading.provider.CascadingFactory<JobConf,Map<cascading.tuple.Tuple,Collection<cascading.tuple.Tuple>>>

create

public Map<cascading.tuple.Tuple,Collection<cascading.tuple.Tuple>> create(cascading.flow.FlowProcess<JobConf> flowProcess)

Specified by:

create in interface cascading.provider.CascadingFactory<JobConf,Map<cascading.tuple.Tuple,Collection<cascading.tuple.Tuple>>>