public class TupleEntrySchemeCollector<Config,Output> extends TupleEntryCollector
Scheme
instance, calling
Scheme.sink(cascading.flow.FlowProcess, cascading.scheme.SinkCall)
on every call to add(TupleEntry)
or add(Tuple)
.
Use this class inside a custom Tap
when overriding the
Tap.openForWrite(cascading.flow.FlowProcess)
method.
Modifier and Type | Field and Description |
---|---|
protected ConcreteCall<java.lang.Object,Output> |
sinkCall |
tupleEntry
Constructor and Description |
---|
TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess,
Scheme scheme)
Deprecated.
|
TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess,
Scheme scheme,
Output output)
Deprecated.
|
TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess,
Scheme scheme,
Output output,
java.lang.String loggableIdentifier)
Deprecated.
|
TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess,
Scheme scheme,
java.lang.String loggableIdentifier)
Deprecated.
|
TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess,
Tap tap,
Output output) |
TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess,
Tap tap,
Scheme scheme) |
TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess,
Tap tap,
Scheme scheme,
Output output) |
TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess,
Tap tap,
Scheme scheme,
Output output,
java.lang.String loggableIdentifier) |
TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess,
Tap tap,
Scheme scheme,
Output output,
java.util.function.Supplier<java.lang.String> loggableIdentifier) |
TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess,
Tap tap,
Scheme scheme,
java.lang.String loggableIdentifier) |
Modifier and Type | Method and Description |
---|---|
void |
add(Tuple tuple)
Method add inserts the given
Tuple into the outgoing stream. |
void |
add(TupleEntry tupleEntry)
Method add inserts the given
TupleEntry into the outgoing stream. |
void |
close()
Method close closes the underlying resource being written to.
|
protected void |
collect(TupleEntry tupleEntry) |
protected <Context,IO> |
createSinkCall()
Override to provide custom ConcreteCall implementation to expose Tap level resources to the underlying Scheme.
|
protected FlowProcess<? extends Config> |
getFlowProcess() |
protected Output |
getOutput() |
protected void |
prepare()
Need to defer preparing the scheme till after the fields have been resolved
|
void |
setFields(Fields declared) |
protected void |
setOutput(Output output) |
protected Output |
wrapOutput(Output output) |
addTuple, addTupleEntry
protected final ConcreteCall<java.lang.Object,Output> sinkCall
@Deprecated public TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess, Scheme scheme)
@Deprecated public TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess, Scheme scheme, java.lang.String loggableIdentifier)
@Deprecated public TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess, Scheme scheme, Output output)
public TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess, Tap tap, Output output)
@Deprecated public TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess, Scheme scheme, Output output, java.lang.String loggableIdentifier)
public TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess, Tap tap, Scheme scheme)
public TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess, Tap tap, Scheme scheme, java.lang.String loggableIdentifier)
public TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess, Tap tap, Scheme scheme, Output output)
public TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess, Tap tap, Scheme scheme, Output output, java.lang.String loggableIdentifier)
public TupleEntrySchemeCollector(FlowProcess<? extends Config> flowProcess, Tap tap, Scheme scheme, Output output, java.util.function.Supplier<java.lang.String> loggableIdentifier)
protected <Context,IO> ConcreteCall<Context,IO> createSinkCall()
protected FlowProcess<? extends Config> getFlowProcess()
public void setFields(Fields declared)
setFields
in class TupleEntryCollector
protected Output wrapOutput(Output output)
protected void prepare()
public void add(TupleEntry tupleEntry)
TupleEntryCollector
TupleEntry
into the outgoing stream. Note the method TupleEntryCollector.add(Tuple)
is
more efficient as it simply calls TupleEntry.getTuple()
;
See TupleEntryCollector
on when and how to re-use a Tuple instance.
add
in class TupleEntryCollector
tupleEntry
- of type TupleEntrypublic void add(Tuple tuple)
TupleEntryCollector
Tuple
into the outgoing stream.
See TupleEntryCollector
on when and how to re-use a Tuple instance.
add
in class TupleEntryCollector
tuple
- of type Tupleprotected void collect(TupleEntry tupleEntry) throws java.io.IOException
collect
in class TupleEntryCollector
java.io.IOException
public void close()
TupleEntryCollector
This method should be called when when an instance is returned via
Tap.openForWrite(cascading.flow.FlowProcess)
and no more Tuple
instances will be written out.
This method must not be called when an instance is returned from getOutputCollector()
from any of
the relevant OperationCall
implementations (inside a Function, Aggregator, or Buffer).
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
close
in class TupleEntryCollector
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.