public abstract class DroolsAbstractBiCollectingGroupByAccumulator<ResultContainer1,ResultContainer2,InTuple,KeyTuple,OutTuple> extends Object implements GroupByAccumulator<InTuple,OutTuple>
Constructor and Description |
---|
DroolsAbstractBiCollectingGroupByAccumulator() |
Modifier and Type | Method and Description |
---|---|
Runnable |
accumulate(InTuple input) |
Set<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 KeyTuple |
toKey(InTuple tuple) |
protected abstract OutTuple |
toResult(KeyTuple key,
ResultContainer1 container,
ResultContainer2 container2) |
public DroolsAbstractBiCollectingGroupByAccumulator()
public Runnable accumulate(InTuple input)
accumulate
in interface GroupByAccumulator<InTuple,OutTuple>
public Set<OutTuple> finish()
finish
in interface GroupByAccumulator<InTuple,OutTuple>
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)
Copyright © 2006–2020 JBoss by Red Hat. All rights reserved.