public class HadoopTupleMapFactory extends java.lang.Object implements cascading.tuple.collect.TupleMapFactory<Configuration>
Constructor and Description |
---|
HadoopTupleMapFactory() |
Modifier and Type | Method and Description |
---|---|
java.util.Map<cascading.tuple.Tuple,java.util.Collection<cascading.tuple.Tuple>> |
create(cascading.flow.FlowProcess<? extends Configuration> flowProcess) |
void |
initialize(cascading.flow.FlowProcess<? extends Configuration> flowProcess) |
public HadoopTupleMapFactory()
public void initialize(cascading.flow.FlowProcess<? extends Configuration> flowProcess)
initialize
in interface cascading.provider.CascadingFactory<Configuration,java.util.Map<cascading.tuple.Tuple,java.util.Collection<cascading.tuple.Tuple>>>
public java.util.Map<cascading.tuple.Tuple,java.util.Collection<cascading.tuple.Tuple>> create(cascading.flow.FlowProcess<? extends Configuration> flowProcess)
create
in interface cascading.provider.CascadingFactory<Configuration,java.util.Map<cascading.tuple.Tuple,java.util.Collection<cascading.tuple.Tuple>>>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.