|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
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 cascading.flow.hadoop.stream.HadoopGroupByGate
public class HadoopGroupByGate
Nested Class Summary |
---|
Nested classes/interfaces inherited from class cascading.flow.stream.SpliceGate |
---|
cascading.flow.stream.SpliceGate.Role |
Field Summary |
---|
Fields inherited from class cascading.flow.hadoop.stream.HadoopGroupGate |
---|
closure, collector |
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 | |
---|---|
HadoopGroupByGate(cascading.flow.FlowProcess flowProcess,
cascading.pipe.GroupBy groupBy,
cascading.flow.stream.SpliceGate.Role role)
|
Method Summary | |
---|---|
void |
prepare()
|
void |
receive(cascading.flow.stream.Duct previous,
cascading.tuple.TupleEntry incomingEntry)
|
protected cascading.tuple.Tuple |
unwrapGrouping(cascading.tuple.Tuple key)
|
Methods inherited from class cascading.flow.hadoop.stream.HadoopGroupGate |
---|
bind, complete, run, start |
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, receiveFirst |
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public HadoopGroupByGate(cascading.flow.FlowProcess flowProcess, cascading.pipe.GroupBy groupBy, cascading.flow.stream.SpliceGate.Role role)
Method Detail |
---|
public void prepare()
prepare
in class HadoopGroupGate
public void receive(cascading.flow.stream.Duct previous, cascading.tuple.TupleEntry incomingEntry)
receive
in class cascading.flow.stream.Duct<cascading.tuple.TupleEntry,cascading.flow.stream.Grouping<cascading.tuple.TupleEntry,cascading.tuple.TupleEntryIterator>>
protected cascading.tuple.Tuple unwrapGrouping(cascading.tuple.Tuple key)
unwrapGrouping
in class HadoopGroupGate
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |