public class TezSourceStage extends cascading.flow.stream.element.SourceStage
Constructor and Description |
---|
TezSourceStage(cascading.flow.FlowProcess flowProcess,
cascading.tap.Tap source,
org.apache.tez.runtime.api.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
public TezSourceStage(cascading.flow.FlowProcess flowProcess, cascading.tap.Tap source, org.apache.tez.runtime.api.LogicalInput logicalInput)
public void prepare()
prepare
in class cascading.flow.stream.duct.Duct<java.lang.Void,cascading.tuple.TupleEntry>
public void run(java.lang.Object input) throws java.lang.Throwable
run
in interface cascading.flow.stream.element.InputSource
run
in class cascading.flow.stream.element.SourceStage
java.lang.Throwable
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.