public class TezSourceStage extends SourceStage
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
Constructor and Description |
---|
TezSourceStage(FlowProcess flowProcess,
Tap source,
LogicalInput logicalInput) |
Modifier and Type | Method and Description |
---|---|
void |
prepare() |
void |
run(java.lang.Object input) |
call, getSource, initialize, receive
cleanup, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
bind, complete, getNext, getNextFor, receiveFirst, start
public TezSourceStage(FlowProcess flowProcess, Tap source, LogicalInput logicalInput)
public void prepare()
prepare
in class Duct<java.lang.Void,TupleEntry>
public void run(java.lang.Object input) throws java.lang.Throwable
run
in interface InputSource
run
in class SourceStage
java.lang.Throwable
Copyright © 2007-2017 Cascading Maintainers. All Rights Reserved.