public abstract class DroolsAbstractBiCollectingGroupByCollectorProcessor<ResultContainer1,ResultContainer2,InTuple,KeyTuple,OutTuple> extends Object
Constructor and Description |
---|
DroolsAbstractBiCollectingGroupByCollectorProcessor() |
Modifier and Type | Method and Description |
---|---|
Runnable |
accumulate(InTuple input) |
protected void |
addTuple(KeyTuple tuple) |
protected Set<KeyTuple> |
clearDirtyTupleSet() |
Collection<OutTuple> |
finish() |
protected abstract ResultContainer1 |
newFirstContainer() |
protected abstract ResultContainer2 |
newSecondContainer() |
protected abstract Runnable |
processFirst(InTuple tuple,
ResultContainer1 container) |
protected abstract Runnable |
processSecond(InTuple tuple,
ResultContainer2 container) |
protected long |
removeTuple(KeyTuple tuple) |
protected abstract KeyTuple |
toKey(InTuple tuple) |
protected abstract OutTuple |
toResult(KeyTuple key,
ResultContainer1 container,
ResultContainer2 container2) |
public DroolsAbstractBiCollectingGroupByCollectorProcessor()
public Collection<OutTuple> finish()
protected abstract ResultContainer1 newFirstContainer()
protected abstract ResultContainer2 newSecondContainer()
protected abstract Runnable processFirst(InTuple tuple, ResultContainer1 container)
protected abstract Runnable processSecond(InTuple tuple, ResultContainer2 container)
protected abstract OutTuple toResult(KeyTuple key, ResultContainer1 container, ResultContainer2 container2)
protected void addTuple(KeyTuple tuple)
protected long removeTuple(KeyTuple tuple)
protected Set<KeyTuple> clearDirtyTupleSet()
Copyright © 2006–2021 JBoss by Red Hat. All rights reserved.