public class HadoopTupleEntrySchemeCollector extends cascading.tuple.TupleEntrySchemeCollector<Configuration,OutputCollector>
TupleEntryCollector
that writes tuples to the resource managed by
a particular Tap
instance.Constructor and Description |
---|
HadoopTupleEntrySchemeCollector(cascading.flow.FlowProcess<? extends Configuration> flowProcess,
cascading.tap.Tap<Configuration,RecordReader,OutputCollector> tap) |
HadoopTupleEntrySchemeCollector(cascading.flow.FlowProcess<? extends Configuration> flowProcess,
cascading.tap.Tap<Configuration,RecordReader,OutputCollector> tap,
OutputCollector outputCollector) |
Modifier and Type | Method and Description |
---|---|
protected OutputCollector<?,?> |
wrapOutput(OutputCollector outputCollector) |
public HadoopTupleEntrySchemeCollector(cascading.flow.FlowProcess<? extends Configuration> flowProcess, cascading.tap.Tap<Configuration,RecordReader,OutputCollector> tap) throws java.io.IOException
java.io.IOException
public HadoopTupleEntrySchemeCollector(cascading.flow.FlowProcess<? extends Configuration> flowProcess, cascading.tap.Tap<Configuration,RecordReader,OutputCollector> tap, OutputCollector outputCollector) throws java.io.IOException
java.io.IOException
protected OutputCollector<?,?> wrapOutput(OutputCollector outputCollector)
wrapOutput
in class cascading.tuple.TupleEntrySchemeCollector<Configuration,OutputCollector>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.