public class SourceStage extends ElementStage<Void,TupleEntry> implements Callable<Throwable>, InputSource
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
Constructor and Description |
---|
SourceStage(FlowProcess flowProcess,
Tap source) |
Modifier and Type | Method and Description |
---|---|
Throwable |
call() |
Tap |
getSource() |
void |
initialize()
Called immediately after bind
|
void |
receive(Duct previous,
Void nada) |
void |
run(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 void run(Object input) throws Throwable
run
in interface InputSource
Throwable
public void initialize()
Duct
initialize
in class Duct<Void,TupleEntry>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.