cascading.flow.hadoop.stream
Class HadoopCoGroupGate
java.lang.Object
cascading.flow.stream.Duct<Incoming,Outgoing>
cascading.flow.stream.Gate<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>
cascading.flow.stream.SpliceGate
cascading.flow.hadoop.stream.HadoopGroupGate
cascading.flow.hadoop.stream.HadoopCoGroupGate
- All Implemented Interfaces:
- Collapsing, ElementDuct
public class HadoopCoGroupGate
- extends HadoopGroupGate
Fields inherited from class cascading.flow.stream.SpliceGate |
flowProcess, grouping, incomingScopes, keyBuilder, keyEntry, keyFields, orderedPrevious, outgoingScopes, role, sortBuilder, sortFields, splice, tupleEntryIterator, valuesBuilder, valuesFields |
Fields inherited from class cascading.flow.stream.Duct |
next |
Methods inherited from class cascading.flow.stream.SpliceGate |
addIncomingScope, addOutgoingScope, cleanup, createDefaultNarrowBuilder, createNarrowBuilder, createNulledBuilder, equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, handleException, handleReThrowableException, hashCode, hasTrapHandler, initialize, makePosMap, orderDucts, setBranchNames, setTrapHandler, toString |
HadoopCoGroupGate
public HadoopCoGroupGate(FlowProcess flowProcess,
CoGroup coGroup,
SpliceGate.Role role)
bind
public void bind(StreamGraph streamGraph)
- Overrides:
bind
in class HadoopGroupGate
prepare
public void prepare()
- Overrides:
prepare
in class HadoopGroupGate
receive
public void receive(Duct previous,
TupleEntry incomingEntry)
- Specified by:
receive
in class Duct<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>
unwrapGrouping
protected Tuple unwrapGrouping(Tuple key)
- Specified by:
unwrapGrouping
in class HadoopGroupGate
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.