public class HadoopTupleMapFactory extends Object implements TupleMapFactory<Configuration>
TUPLE_MAP_FACTORY
Constructor and Description |
---|
HadoopTupleMapFactory() |
Modifier and Type | Method and Description |
---|---|
Map<Tuple,Collection<Tuple>> |
create(FlowProcess<? extends Configuration> flowProcess) |
void |
initialize(FlowProcess<? extends Configuration> flowProcess) |
public HadoopTupleMapFactory()
public void initialize(FlowProcess<? extends Configuration> flowProcess)
initialize
in interface CascadingFactory<Configuration,Map<Tuple,Collection<Tuple>>>
public Map<Tuple,Collection<Tuple>> create(FlowProcess<? extends Configuration> flowProcess)
create
in interface CascadingFactory<Configuration,Map<Tuple,Collection<Tuple>>>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.