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 Comparator<Tuple>[] |
groupComparators |
protected TupleHasher |
groupHasher |
protected Grouping<TupleEntry,TupleEntryIterator> |
grouping |
protected TupleBuilder[] |
keyBuilder |
protected TupleEntry |
keyEntry |
protected Fields[] |
keyFields |
protected boolean |
nullsAreNotEqual |
protected Map<Duct,Integer> |
ordinalMap |
protected TupleBuilder[] |
sortBuilder |
protected Fields[] |
sortFields |
protected TupleEntryChainIterator |
tupleEntryIterator |
protected Comparator<Tuple>[] |
valueComparators |
protected TupleBuilder[] |
valuesBuilder |
protected Fields[] |
valuesFields |
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 |
bind(StreamGraph streamGraph) |
void |
cleanup() |
protected TupleBuilder |
createDefaultNarrowBuilder(Fields incomingFields,
Fields narrowFields) |
protected TupleBuilder |
createNarrowBuilder(Fields incomingFields,
Fields narrowFields) |
protected TupleBuilder |
createNulledBuilder(Fields incomingFields,
Fields keyField) |
boolean |
equals(Object object) |
protected Tuple |
getDelegatedTuple(Tuple object)
This allows the tuple to honor the hasher and comparators, if any
|
protected Comparator |
getKeyComparator() |
protected int |
getNumDeclaredIncomingBranches() |
int |
hashCode() |
protected void |
initComparators() |
void |
initialize()
Called immediately after bind
|
protected void |
setOrdinalMap(StreamGraph streamGraph) |
String |
toString() |
getBranchNames, getFlowElement, getIncomingScopes, getOutgoingScopes, getSplice, handleException, handleReThrowableException, hasTrapHandler, setBranchNames, setTrapHandler
complete, getNext, getNextFor, prepare, receive, receiveFirst, start
protected Map<Duct,Integer> ordinalMap
protected Fields[] sortFields
protected Fields[] valuesFields
protected Comparator<Tuple>[] groupComparators
protected Comparator<Tuple>[] valueComparators
protected TupleHasher groupHasher
protected boolean nullsAreNotEqual
protected TupleBuilder[] keyBuilder
protected TupleBuilder[] valuesBuilder
protected TupleBuilder[] sortBuilder
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)
public void bind(StreamGraph streamGraph)
bind
in class Duct<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>
protected void setOrdinalMap(StreamGraph streamGraph)
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 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 wrappublic String toString()
toString
in class Duct<TupleEntry,Grouping<TupleEntry,TupleEntryIterator>>
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.