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