public abstract class OperatorStage<Incoming> extends ElementStage<Incoming,TupleEntry>
Modifier and Type | Field and Description |
---|---|
protected TupleBuilder |
argumentsBuilder |
protected TupleEntry |
argumentsEntry |
protected Fields |
argumentsSelector |
protected TupleEntry |
incomingEntry |
protected ConcreteCall |
operationCall |
protected TupleBuilder |
outgoingBuilder |
protected TupleEntry |
outgoingEntry |
protected Fields |
outgoingSelector |
protected TupleEntryCollector |
outputCollector |
protected Fields |
remainderFields |
static java.lang.String |
RETAIN_COLLECTOR
In 2.2 the collector is now nulled before the
Operation.cleanup(cascading.flow.FlowProcess, cascading.operation.OperationCall)
is called. |
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
Constructor and Description |
---|
OperatorStage(FlowProcess flowProcess,
FlowElement flowElement) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
void |
complete(Duct previous) |
protected TupleBuilder |
createArgumentsBuilder(Fields incomingFields,
Fields argumentsSelector) |
protected TupleBuilder |
createOutgoingBuilder(Operator operator,
Fields incomingFields,
Fields argumentSelector,
Fields remainderFields,
Fields declaredFields,
Fields outgoingSelector) |
protected abstract Fields |
getIncomingArgumentsFields() |
protected abstract Fields |
getIncomingPassThroughFields() |
protected Fields |
getOperationDeclaredFields() |
abstract Operator |
getOperator() |
protected abstract Fields |
getOutgoingSelector() |
void |
initialize()
Called immediately after bind
|
void |
prepare() |
equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
bind, getNext, getNextFor, receiveFirst, start
public static final java.lang.String RETAIN_COLLECTOR
Operation.cleanup(cascading.flow.FlowProcess, cascading.operation.OperationCall)
is called. This property retains the collector to remain compatible with 2.1.protected ConcreteCall operationCall
protected TupleEntry incomingEntry
protected Fields argumentsSelector
protected TupleEntry argumentsEntry
protected Fields remainderFields
protected Fields outgoingSelector
protected TupleEntry outgoingEntry
protected TupleBuilder argumentsBuilder
protected TupleBuilder outgoingBuilder
protected TupleEntryCollector outputCollector
public OperatorStage(FlowProcess flowProcess, FlowElement flowElement)
public abstract Operator getOperator()
protected abstract Fields getOutgoingSelector()
protected Fields getOperationDeclaredFields()
protected abstract Fields getIncomingPassThroughFields()
protected abstract Fields getIncomingArgumentsFields()
protected TupleBuilder createArgumentsBuilder(Fields incomingFields, Fields argumentsSelector)
protected TupleBuilder createOutgoingBuilder(Operator operator, Fields incomingFields, Fields argumentSelector, Fields remainderFields, Fields declaredFields, Fields outgoingSelector)
public void initialize()
Duct
initialize
in class Duct<Incoming,TupleEntry>
public void prepare()
prepare
in class Duct<Incoming,TupleEntry>
public void cleanup()
cleanup
in class ElementStage<Incoming,TupleEntry>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.