|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object cascading.tuple.TupleEntryCollector
public abstract class TupleEntryCollector
Interface TupleEntryCollector is used to allow BaseOperation
instances to emit result Tuple
values.
Field Summary | |
---|---|
protected Fields |
declared
Field declared |
Constructor Summary | |
---|---|
protected |
TupleEntryCollector()
|
|
TupleEntryCollector(Fields declared)
Constructor TupleCollector creates a new TupleCollector instance. |
Method Summary | |
---|---|
void |
add(Tuple tuple)
Method add inserts the given Tuple into the outgoing stream. |
void |
add(TupleEntry entry)
Method add inserts the given TupleEntry into the outgoing stream. |
void |
close()
Method close closes the underlying resource being written to. |
protected abstract void |
collect(Tuple tuple)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected Fields declared
Constructor Detail |
---|
protected TupleEntryCollector()
public TupleEntryCollector(Fields declared)
declared
- of type FieldsMethod Detail |
---|
public void add(TupleEntry entry)
TupleEntry
into the outgoing stream. Note the method add(Tuple)
is
more efficient as it simply calls TupleEntry.getTuple()
;
entry
- of type TupleEntrypublic void add(Tuple tuple)
Tuple
into the outgoing stream.
tuple
- of type Tupleprotected abstract void collect(Tuple tuple)
public void close()
Tuple
instances will be written out.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |