cascading.flow.hadoop.stream
Class HadoopSinkStage
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
cascading.flow.hadoop.stream.HadoopSinkStage
- All Implemented Interfaces:
- ElementDuct
public class HadoopSinkStage
- extends SinkStage
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 |
HadoopSinkStage
public HadoopSinkStage(FlowProcess flowProcess,
Tap sink)
getOutput
protected Object getOutput()
- Overrides:
getOutput
in class SinkStage
Copyright © 2007-2014 Concurrent, Inc. All Rights Reserved.