public class TezSinkStage extends SinkStage
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
Constructor and Description |
---|
TezSinkStage(FlowProcess flowProcess,
Tap sink,
LogicalOutput logicalOutput) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
protected java.lang.Object |
getOutput() |
void |
prepare() |
bind, complete, getSink, receive, start, timedAdd
equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
getNext, getNextFor, initialize, receiveFirst
public TezSinkStage(FlowProcess flowProcess, Tap sink, LogicalOutput logicalOutput)
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.