cascading.tuple.hadoop.collect
Class HadoopTupleCollectionFactory

java.lang.Object
  extended by cascading.tuple.hadoop.collect.HadoopTupleCollectionFactory
All Implemented Interfaces:
cascading.provider.CascadingFactory<JobConf,Collection<cascading.tuple.Tuple>>, cascading.tuple.collect.TupleCollectionFactory<JobConf>

public class HadoopTupleCollectionFactory
extends Object
implements cascading.tuple.collect.TupleCollectionFactory<JobConf>


Field Summary
 
Fields inherited from interface cascading.tuple.collect.TupleCollectionFactory
TUPLE_COLLECTION_FACTORY
 
Constructor Summary
HadoopTupleCollectionFactory()
           
 
Method Summary
 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

HadoopTupleCollectionFactory

public HadoopTupleCollectionFactory()
Method Detail

initialize

public void initialize(cascading.flow.FlowProcess<JobConf> flowProcess)
Specified by:
initialize in interface cascading.provider.CascadingFactory<JobConf,Collection<cascading.tuple.Tuple>>

create

public Collection<cascading.tuple.Tuple> create(cascading.flow.FlowProcess<JobConf> flowProcess)
Specified by:
create in interface cascading.provider.CascadingFactory<JobConf,Collection<cascading.tuple.Tuple>>


Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.