public class SinkStage extends ElementStage<TupleEntry,java.lang.Void>
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
Constructor and Description |
---|
SinkStage(FlowProcess flowProcess,
Tap sink) |
Modifier and Type | Method and Description |
---|---|
void |
bind(StreamGraph streamGraph) |
void |
cleanup() |
void |
complete(Duct previous) |
protected java.lang.Object |
getOutput() |
Tap |
getSink() |
void |
prepare() |
void |
receive(Duct previous,
int ordinal,
TupleEntry tupleEntry) |
void |
start(Duct previous) |
equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
getNext, getNextFor, initialize, receiveFirst
public SinkStage(FlowProcess flowProcess, Tap sink)
public void bind(StreamGraph streamGraph)
bind
in class Duct<TupleEntry,java.lang.Void>
public void prepare()
prepare
in class Duct<TupleEntry,java.lang.Void>
protected java.lang.Object getOutput()
public void start(Duct previous)
start
in class Duct<TupleEntry,java.lang.Void>
public void receive(Duct previous, int ordinal, TupleEntry tupleEntry)
receive
in class Stage<TupleEntry,java.lang.Void>
public void complete(Duct previous)
complete
in class Duct<TupleEntry,java.lang.Void>
public void cleanup()
cleanup
in class ElementStage<TupleEntry,java.lang.Void>
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.