cascading.flow.stream
Class OperatorStage<Incoming>
java.lang.Object
cascading.flow.stream.Duct<Incoming,Outgoing>
cascading.flow.stream.Stage<Incoming,Outgoing>
cascading.flow.stream.ElementStage<Incoming,TupleEntry>
cascading.flow.stream.OperatorStage<Incoming>
- All Implemented Interfaces:
- ElementDuct
- Direct Known Subclasses:
- EachStage, EveryStage
public abstract class OperatorStage<Incoming>
- extends ElementStage<Incoming,TupleEntry>
Fields inherited from class cascading.flow.stream.Duct |
next |
Methods inherited from class cascading.flow.stream.ElementStage |
addIncomingScope, addOutgoingScope, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString |
Methods inherited from class cascading.flow.stream.Stage |
receive |
RETAIN_COLLECTOR
public static final String RETAIN_COLLECTOR
- In 2.2 the collector is now nulled before the
Operation.cleanup(cascading.flow.FlowProcess, cascading.operation.OperationCall)
is called. This property retains the collector to remain compatible with 2.1.
- See Also:
- Constant Field Values
operationCall
protected ConcreteCall operationCall
incomingEntry
protected TupleEntry incomingEntry
argumentsSelector
protected Fields argumentsSelector
argumentsEntry
protected TupleEntry argumentsEntry
remainderFields
protected Fields remainderFields
outgoingSelector
protected Fields outgoingSelector
outgoingEntry
protected TupleEntry outgoingEntry
argumentsBuilder
protected TupleBuilder argumentsBuilder
outgoingBuilder
protected TupleBuilder outgoingBuilder
outputCollector
protected TupleEntryCollector outputCollector
OperatorStage
public OperatorStage(FlowProcess flowProcess,
FlowElement flowElement)
getOperator
public abstract Operator getOperator()
getOutgoingSelector
protected abstract Fields getOutgoingSelector()
getOperationDeclaredFields
protected Fields getOperationDeclaredFields()
getIncomingPassThroughFields
protected abstract Fields getIncomingPassThroughFields()
getIncomingArgumentsFields
protected abstract Fields getIncomingArgumentsFields()
createArgumentsBuilder
protected TupleBuilder createArgumentsBuilder(Fields incomingFields,
Fields argumentsSelector)
createOutgoingBuilder
protected TupleBuilder createOutgoingBuilder(Operator operator,
Fields incomingFields,
Fields argumentSelector,
Fields remainderFields,
Fields declaredFields,
Fields outgoingSelector)
initialize
public void initialize()
- Description copied from class:
Duct
- Called immediately after bind
- Overrides:
initialize
in class Duct<Incoming,TupleEntry>
prepare
public void prepare()
- Overrides:
prepare
in class Duct<Incoming,TupleEntry>
complete
public void complete(Duct previous)
- Overrides:
complete
in class Duct<Incoming,TupleEntry>
cleanup
public void cleanup()
- Overrides:
cleanup
in class ElementStage<Incoming,TupleEntry>
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.