public class TapOutputCollector extends Object implements OutputCollector, Closeable
Modifier and Type | Field and Description |
---|---|
static String |
PART_TASK_PATTERN |
static String |
PART_TASK_SEQ_PATTERN |
Constructor and Description |
---|
TapOutputCollector(FlowProcess<? extends Configuration> flowProcess,
Tap<Configuration,RecordReader,OutputCollector> tap) |
TapOutputCollector(FlowProcess<? extends Configuration> flowProcess,
Tap<Configuration,RecordReader,OutputCollector> tap,
String prefix) |
TapOutputCollector(FlowProcess<? extends Configuration> flowProcess,
Tap<Configuration,RecordReader,OutputCollector> tap,
String prefix,
long sequence) |
public static final String PART_TASK_PATTERN
public static final String PART_TASK_SEQ_PATTERN
public TapOutputCollector(FlowProcess<? extends Configuration> flowProcess, Tap<Configuration,RecordReader,OutputCollector> tap) throws IOException
IOException
public TapOutputCollector(FlowProcess<? extends Configuration> flowProcess, Tap<Configuration,RecordReader,OutputCollector> tap, String prefix) throws IOException
IOException
public TapOutputCollector(FlowProcess<? extends Configuration> flowProcess, Tap<Configuration,RecordReader,OutputCollector> tap, String prefix, long sequence) throws IOException
IOException
protected void initialize() throws IOException
IOException
public void collect(Object writableComparable, Object writable) throws IOException
Tap
this instance encapsulates.collect
in interface OutputCollector
writableComparable
- of type WritableComparablewritable
- of type WritableIOException
- whenpublic void close()
close
in interface Closeable
close
in interface AutoCloseable
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.