public class SourceStage extends ElementStage<java.lang.Void,TupleEntry> implements java.util.concurrent.Callable<java.lang.Throwable>, InputSource
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
Constructor and Description |
---|
SourceStage(FlowProcess flowProcess,
Tap source) |
Modifier and Type | Method and Description |
---|---|
java.lang.Throwable |
call() |
Tap |
getSource() |
void |
initialize()
Called immediately after bind
|
void |
receive(Duct previous,
int ordinal,
java.lang.Void nada) |
void |
run(java.lang.Object input) |
cleanup, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
bind, complete, getNext, getNextFor, prepare, receiveFirst, start
public SourceStage(FlowProcess flowProcess, Tap source)
public java.lang.Throwable call() throws java.lang.Exception
call
in interface java.util.concurrent.Callable<java.lang.Throwable>
java.lang.Exception
public void run(java.lang.Object input) throws java.lang.Throwable
run
in interface InputSource
java.lang.Throwable
public void initialize()
Duct
initialize
in class Duct<java.lang.Void,TupleEntry>
public void receive(Duct previous, int ordinal, java.lang.Void nada)
receive
in class Stage<java.lang.Void,TupleEntry>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.