public class HadoopSinkStage extends SinkStage
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
Constructor and Description |
---|
HadoopSinkStage(FlowProcess flowProcess,
Tap sink) |
Modifier and Type | Method and Description |
---|---|
protected Object |
getOutput() |
bind, cleanup, complete, getSink, prepare, receive, start
equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
getNext, getNextFor, initialize, receiveFirst
public HadoopSinkStage(FlowProcess flowProcess, Tap sink)
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.