cascading.flow.hadoop.stream
Class HadoopGroupGate
java.lang.Object
cascading.flow.stream.Duct<Incoming,Outgoing>
cascading.flow.stream.Gate<cascading.tuple.TupleEntry,cascading.flow.stream.Grouping<cascading.tuple.TupleEntry,cascading.tuple.TupleEntryIterator>>
cascading.flow.stream.SpliceGate
cascading.flow.hadoop.stream.HadoopGroupGate
- All Implemented Interfaces:
- cascading.flow.stream.Collapsing, cascading.flow.stream.ElementDuct
- Direct Known Subclasses:
- HadoopCoGroupGate, HadoopGroupByGate
public abstract class HadoopGroupGate
- extends cascading.flow.stream.SpliceGate
Nested classes/interfaces inherited from class cascading.flow.stream.SpliceGate |
cascading.flow.stream.SpliceGate.Role |
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.Gate |
allPrevious |
Fields inherited from class cascading.flow.stream.Duct |
next |
Constructor Summary |
HadoopGroupGate(cascading.flow.FlowProcess flowProcess,
cascading.pipe.Splice splice,
cascading.flow.stream.SpliceGate.Role role)
|
Method Summary |
void |
bind(cascading.flow.stream.StreamGraph streamGraph)
|
void |
complete(cascading.flow.stream.Duct previous)
|
void |
prepare()
|
void |
run(cascading.tuple.Tuple key,
Iterator values)
|
void |
start(cascading.flow.stream.Duct previous)
|
protected abstract cascading.tuple.Tuple |
unwrapGrouping(cascading.tuple.Tuple key)
|
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 |
Methods inherited from class cascading.flow.stream.Gate |
getAllPreviousFor |
Methods inherited from class cascading.flow.stream.Duct |
getNext, getNextFor, receive, receiveFirst |
closure
protected HadoopGroupByClosure closure
collector
protected OutputCollector collector
HadoopGroupGate
public HadoopGroupGate(cascading.flow.FlowProcess flowProcess,
cascading.pipe.Splice splice,
cascading.flow.stream.SpliceGate.Role role)
bind
public void bind(cascading.flow.stream.StreamGraph streamGraph)
- Overrides:
bind
in class cascading.flow.stream.Gate<cascading.tuple.TupleEntry,cascading.flow.stream.Grouping<cascading.tuple.TupleEntry,cascading.tuple.TupleEntryIterator>>
prepare
public void prepare()
- Overrides:
prepare
in class cascading.flow.stream.Duct<cascading.tuple.TupleEntry,cascading.flow.stream.Grouping<cascading.tuple.TupleEntry,cascading.tuple.TupleEntryIterator>>
start
public void start(cascading.flow.stream.Duct previous)
- Overrides:
start
in class cascading.flow.stream.Duct<cascading.tuple.TupleEntry,cascading.flow.stream.Grouping<cascading.tuple.TupleEntry,cascading.tuple.TupleEntryIterator>>
complete
public void complete(cascading.flow.stream.Duct previous)
- Overrides:
complete
in class cascading.flow.stream.Duct<cascading.tuple.TupleEntry,cascading.flow.stream.Grouping<cascading.tuple.TupleEntry,cascading.tuple.TupleEntryIterator>>
run
public void run(cascading.tuple.Tuple key,
Iterator values)
unwrapGrouping
protected abstract cascading.tuple.Tuple unwrapGrouping(cascading.tuple.Tuple key)
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.