public abstract class GroupingSpliceGate extends SpliceGate<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>> implements Window
Modifier and Type | Class and Description |
---|---|
protected class |
GroupingSpliceGate.DelegatedTuple |
Modifier and Type | Field and Description |
---|---|
protected java.util.Comparator<Tuple>[] |
groupComparators |
protected TupleHasher |
groupHasher |
protected Grouping<TupleEntry,TupleEntryIterator> |
grouping |
protected Resettable2<Tuple,Tuple> |
groupSortTuple |
protected Resettable1<Tuple> |
groupTuple |
protected TupleBuilder[] |
keyBuilder |
protected TupleEntry |
keyEntry |
protected Fields[] |
keyFields |
protected Tuple |
keyTuple |
protected boolean |
nullsAreNotEqual |
protected TupleBuilder[] |
sortBuilder |
protected Fields[] |
sortFields |
protected TupleEntryChainIterator |
tupleEntryIterator |
protected java.util.Comparator<Tuple>[] |
valueComparators |
protected TupleBuilder[] |
valuesBuilder |
protected Fields[] |
valuesFields |
protected Resettable1<Tuple> |
valueTuple |
flowProcess, incomingScopes, outgoingScopes, role, splice
Modifier | Constructor and Description |
---|---|
protected |
GroupingSpliceGate(FlowProcess flowProcess,
Splice splice) |
protected |
GroupingSpliceGate(FlowProcess flowProcess,
Splice splice,
IORole role) |
Modifier and Type | Method and Description |
---|---|
void |
cleanup() |
protected TupleBuilder |
createDefaultNarrowBuilder(Fields incomingFields,
Fields narrowFields) |
protected TupleBuilder |
createNarrowBuilder(Fields incomingFields,
Fields narrowFields) |
protected TupleBuilder |
createNulledBuilder(Fields incomingFields,
Fields keyField) |
protected Tuple |
getDelegatedTuple(Tuple object)
This allows the tuple to honor the hasher and comparators, if any
|
protected java.util.Comparator |
getKeyComparator() |
protected int |
getNumDeclaredIncomingBranches() |
protected void |
initComparators() |
void |
initialize()
Called immediately after bind
|
equals, getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, getSplice, handleException, handleReThrowableException, hashCode, hasTrapHandler, setBranchNames, setTrapHandler, toString
bind, complete, getNext, getNextFor, prepare, receive, receiveFirst, start
protected Fields[] sortFields
protected Fields[] valuesFields
protected java.util.Comparator<Tuple>[] groupComparators
protected java.util.Comparator<Tuple>[] valueComparators
protected TupleHasher groupHasher
protected boolean nullsAreNotEqual
protected TupleBuilder[] keyBuilder
protected TupleBuilder[] valuesBuilder
protected TupleBuilder[] sortBuilder
protected Resettable1<Tuple> groupTuple
protected Resettable2<Tuple,Tuple> groupSortTuple
protected Resettable1<Tuple> valueTuple
protected Grouping<TupleEntry,TupleEntryIterator> grouping
protected TupleEntry keyEntry
protected TupleEntryChainIterator tupleEntryIterator
protected GroupingSpliceGate(FlowProcess flowProcess, Splice splice)
protected GroupingSpliceGate(FlowProcess flowProcess, Splice splice, IORole role)
protected TupleBuilder createNarrowBuilder(Fields incomingFields, Fields narrowFields)
protected TupleBuilder createDefaultNarrowBuilder(Fields incomingFields, Fields narrowFields)
protected TupleBuilder createNulledBuilder(Fields incomingFields, Fields keyField)
public void initialize()
Duct
initialize
in class SpliceGate<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>
protected void initComparators()
protected java.util.Comparator getKeyComparator()
public void cleanup()
cleanup
in class Duct<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>
protected int getNumDeclaredIncomingBranches()
protected final Tuple getDelegatedTuple(Tuple object)
object
- the tuple to wrapCopyright © 2007-2015 Xplenty, Inc. All Rights Reserved.