cascading.flow.stream
Class SinkStage
java.lang.Object
cascading.flow.stream.Duct<Incoming,Outgoing>
cascading.flow.stream.Stage<Incoming,Outgoing>
cascading.flow.stream.ElementStage<TupleEntry,Void>
cascading.flow.stream.SinkStage
- All Implemented Interfaces:
- ElementDuct
public class SinkStage
- extends ElementStage<TupleEntry,Void>
Fields inherited from class cascading.flow.stream.Duct |
next |
Methods inherited from class cascading.flow.stream.ElementStage |
addIncomingScope, addOutgoingScope, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString |
SinkStage
public SinkStage(FlowProcess flowProcess,
Tap sink)
bind
public void bind(StreamGraph streamGraph)
- Overrides:
bind
in class Duct<TupleEntry,Void>
prepare
public void prepare()
- Overrides:
prepare
in class Duct<TupleEntry,Void>
getOutput
protected Object getOutput()
start
public void start(Duct previous)
- Overrides:
start
in class Duct<TupleEntry,Void>
receive
public void receive(Duct previous,
TupleEntry tupleEntry)
- Overrides:
receive
in class Stage<TupleEntry,Void>
complete
public void complete(Duct previous)
- Overrides:
complete
in class Duct<TupleEntry,Void>
cleanup
public void cleanup()
- Overrides:
cleanup
in class ElementStage<TupleEntry,Void>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.