- java.lang.Object
-
- cascading.flow.stream.duct.Duct<Incoming,Outgoing>
-
- cascading.flow.stream.duct.Stage<Incoming,Outgoing>
-
- cascading.flow.stream.element.ElementStage<cascading.tuple.TupleEntry,java.lang.Void>
-
- cascading.flow.stream.element.SinkStage
-
- cascading.flow.hadoop.stream.element.HadoopSinkStage
-
-
Field Summary
-
Fields inherited from class cascading.flow.stream.element.ElementStage
branchNames, flowElement, flowProcess, incomingScopes, outgoingScopes, trapHandler
-
Fields inherited from class cascading.flow.stream.duct.Duct
next
-
Constructor Summary
Constructors
Constructor and Description |
HadoopSinkStage(cascading.flow.FlowProcess flowProcess,
cascading.tap.Tap sink) |
-
Method Summary
Methods
Modifier and Type |
Method and Description |
protected java.lang.Object |
getOutput() |
-
Methods inherited from class cascading.flow.stream.element.SinkStage
bind, cleanup, complete, getSink, prepare, receive, start
-
Methods inherited from class cascading.flow.stream.element.ElementStage
equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingFields, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
-
Methods inherited from class cascading.flow.stream.duct.Duct
getNext, getNextFor, initialize, receiveFirst
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.