public class HadoopTupleEntrySchemeCollector extends TupleEntrySchemeCollector<Configuration,OutputCollector>
TupleEntryCollector
that writes tuples to the resource managed by
a particular Tap
instance.sinkCall
tupleEntry
Constructor and Description |
---|
HadoopTupleEntrySchemeCollector(FlowProcess<? extends Configuration> flowProcess,
Tap<Configuration,RecordReader,OutputCollector> tap) |
HadoopTupleEntrySchemeCollector(FlowProcess<? extends Configuration> flowProcess,
Tap<Configuration,RecordReader,OutputCollector> tap,
OutputCollector outputCollector) |
Modifier and Type | Method and Description |
---|---|
protected OutputCollector<?,?> |
wrapOutput(OutputCollector outputCollector) |
add, add, close, collect, getFlowProcess, getOutput, prepare, setFields, setOutput
public HadoopTupleEntrySchemeCollector(FlowProcess<? extends Configuration> flowProcess, Tap<Configuration,RecordReader,OutputCollector> tap) throws IOException
IOException
public HadoopTupleEntrySchemeCollector(FlowProcess<? extends Configuration> flowProcess, Tap<Configuration,RecordReader,OutputCollector> tap, OutputCollector outputCollector) throws IOException
IOException
protected OutputCollector<?,?> wrapOutput(OutputCollector outputCollector)
wrapOutput
in class TupleEntrySchemeCollector<Configuration,OutputCollector>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.