public class ResultSetProcessorAggregateGroupedOutputLastHelperImpl extends Object implements ResultSetProcessorAggregateGroupedOutputLastHelper
Constructor and Description |
---|
ResultSetProcessorAggregateGroupedOutputLastHelperImpl(ResultSetProcessorAggregateGrouped processor) |
Modifier and Type | Method and Description |
---|---|
void |
destroy() |
UniformPair<EventBean[]> |
outputJoin(boolean isSynthesize) |
UniformPair<EventBean[]> |
outputView(boolean isSynthesize) |
void |
processJoin(Set<MultiKey<EventBean>> newData,
Set<MultiKey<EventBean>> oldData,
boolean isGenerateSynthetic) |
void |
processView(EventBean[] newData,
EventBean[] oldData,
boolean isGenerateSynthetic) |
void |
remove(Object key) |
public ResultSetProcessorAggregateGroupedOutputLastHelperImpl(ResultSetProcessorAggregateGrouped processor)
public void processView(EventBean[] newData, EventBean[] oldData, boolean isGenerateSynthetic)
processView
in interface ResultSetProcessorAggregateGroupedOutputLastHelper
public void processJoin(Set<MultiKey<EventBean>> newData, Set<MultiKey<EventBean>> oldData, boolean isGenerateSynthetic)
processJoin
in interface ResultSetProcessorAggregateGroupedOutputLastHelper
public UniformPair<EventBean[]> outputView(boolean isSynthesize)
outputView
in interface ResultSetProcessorAggregateGroupedOutputLastHelper
public UniformPair<EventBean[]> outputJoin(boolean isSynthesize)
outputJoin
in interface ResultSetProcessorAggregateGroupedOutputLastHelper
public void remove(Object key)
remove
in interface ResultSetProcessorAggregateGroupedOutputLastHelper
public void destroy()
destroy
in interface ResultSetProcessorAggregateGroupedOutputLastHelper