cascading.flow.stream
Class EveryStage<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>
cascading.flow.stream.EveryStage<Incoming>
- All Implemented Interfaces:
- ElementDuct
- Direct Known Subclasses:
- AggregatorEveryStage, BufferEveryWindow, GroupAssertionEveryStage
public abstract class EveryStage<Incoming>
- extends OperatorStage<Incoming>
Fields inherited from class cascading.flow.stream.OperatorStage |
argumentsBuilder, argumentsEntry, argumentsSelector, incomingEntry, operationCall, outgoingBuilder, outgoingEntry, outgoingSelector, outputCollector, remainderFields, RETAIN_COLLECTOR |
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 |
EveryStage
public EveryStage(FlowProcess flowProcess,
Every every)
getOperator
public Operator getOperator()
- Specified by:
getOperator
in class OperatorStage<Incoming>
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.