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