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>
Fields inherited from interface cascading.tuple.collect.TupleMapFactory |
TUPLE_MAP_FACTORY |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HadoopTupleMapFactory
public HadoopTupleMapFactory()
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>>>
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.