S
- current state of the processorpublic abstract class GroupingWindowProcessor<S extends State> extends WindowProcessor<S>
Modifier and Type | Class and Description |
---|---|
class |
GroupingWindowProcessor.GroupingKeyPopulator
Populates grouping key to the complex event
|
Modifier and Type | Field and Description |
---|---|
protected GroupingWindowProcessor.GroupingKeyPopulator |
groupingKeyPopulator |
protected List<io.siddhi.query.api.definition.Attribute> |
internalAttributes |
attributeExpressionExecutors, attributeExpressionLength, complexEventPopulater, inputDefinition, metaStreamEvent, nextProcessor, siddhiQueryContext, stateHolder, streamEventClonerHolder
Constructor and Description |
---|
GroupingWindowProcessor() |
Modifier and Type | Method and Description |
---|---|
void |
constructStreamEventPopulater(MetaStreamEvent metaStreamEvent,
int streamEventChainIndex) |
ProcessingMode |
getProcessingMode()
Defines the behaviour of the processing, will be called after the init
|
protected abstract StateFactory<S> |
init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext)
The init method of the WindowProcessor, this method will be called before other methods
|
protected StateFactory<S> |
init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext)
The init method of the StreamProcessor, this method will be called before other methods
|
protected void |
processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
ComplexEventPopulater complexEventPopulater,
S state)
The main processing method that will be called upon event arrival
|
protected abstract void |
processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk,
Processor nextProcessor,
StreamEventCloner streamEventCloner,
GroupingWindowProcessor.GroupingKeyPopulator groupingKeyPopulater,
S state)
The main processing method that will be called upon event arrival
|
getReturnAttributes
getNextProcessor, initProcessor, process, setNextProcessor, setStreamEventCloner, setToLast
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
start, stop
protected List<io.siddhi.query.api.definition.Attribute> internalAttributes
protected GroupingWindowProcessor.GroupingKeyPopulator groupingKeyPopulator
protected StateFactory<S> init(MetaStreamEvent metaStreamEvent, io.siddhi.query.api.definition.AbstractDefinition inputDefinition, ExpressionExecutor[] attributeExpressionExecutors, ConfigReader configReader, StreamEventClonerHolder streamEventClonerHolder, boolean outputExpectsExpiredEvents, boolean findToBeExecuted, SiddhiQueryContext siddhiQueryContext)
AbstractStreamProcessor
init
in class AbstractStreamProcessor<S extends State>
metaStreamEvent
- the stream event metainputDefinition
- the incoming stream definitionattributeExpressionExecutors
- the executors of each function parametersconfigReader
- this hold the AbstractStreamProcessor
extensions configurationstreamEventClonerHolder
- stream event cloner holderoutputExpectsExpiredEvents
- is expired events sent as outputfindToBeExecuted
- find will be executedsiddhiQueryContext
- current siddhi query contextprotected abstract StateFactory<S> init(ExpressionExecutor[] attributeExpressionExecutors, ConfigReader configReader, boolean outputExpectsExpiredEvents, SiddhiQueryContext siddhiQueryContext)
attributeExpressionExecutors
- the executors of each function parametersconfigReader
- the config reader of windowoutputExpectsExpiredEvents
- is expired events sent as outputsiddhiQueryContext
- the context of the siddhi queryprotected void processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk, Processor nextProcessor, StreamEventCloner streamEventCloner, ComplexEventPopulater complexEventPopulater, S state)
AbstractStreamProcessor
processEventChunk
in class AbstractStreamProcessor<S extends State>
streamEventChunk
- the event chunk that need to be processednextProcessor
- the next processor to which the success events need to be passedstreamEventCloner
- helps to clone the incoming event for local storage or modificationcomplexEventPopulater
- helps to populate the events with the resultant attributesstate
- current state of the processorprotected abstract void processEventChunk(ComplexEventChunk<StreamEvent> streamEventChunk, Processor nextProcessor, StreamEventCloner streamEventCloner, GroupingWindowProcessor.GroupingKeyPopulator groupingKeyPopulater, S state)
streamEventChunk
- the event chunk that need to be processednextProcessor
- the next processor to which the success events need to be passedstreamEventCloner
- helps to clone the incoming event for local storage or modificationgroupingKeyPopulater
- helps to populate the events with the grouping keystate
- current state of the processorpublic void constructStreamEventPopulater(MetaStreamEvent metaStreamEvent, int streamEventChainIndex)
constructStreamEventPopulater
in class AbstractStreamProcessor<S extends State>
public ProcessingMode getProcessingMode()
AbstractStreamProcessor
getProcessingMode
in class AbstractStreamProcessor<S extends State>
Copyright © 2019. All rights reserved.