Constructor and Description |
---|
QuerySelector(String id,
io.siddhi.query.api.execution.query.selection.Selector selector,
boolean currentOn,
boolean expiredOn,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
ComplexEventChunk |
execute(ComplexEventChunk complexEventChunk) |
List<AttributeProcessor> |
getAttributeProcessorList() |
Processor |
getNextProcessor()
Get next processor element in the processor chain.
|
void |
process(ComplexEventChunk complexEventChunk)
Process the handed StreamEvent
|
void |
process(List<ComplexEventChunk> complexEventChunks)
Process the handed StreamEvent
|
void |
setAttributeProcessorList(List<AttributeProcessor> attributeProcessorList,
boolean containsAggregator) |
void |
setBatchingEnabled(boolean batchingEnabled) |
void |
setEventPopulator(StateEventPopulator eventPopulator) |
void |
setGroupByKeyGenerator(GroupByKeyGenerator groupByKeyGenerator) |
void |
setHavingConditionExecutor(ConditionExpressionExecutor havingConditionExecutor,
boolean containsAggregator) |
void |
setLimit(long limit) |
void |
setNextProcessor(OutputRateLimiter outputRateLimiter) |
void |
setNextProcessor(Processor processor)
Set next processor element in processor chain
|
void |
setOffset(long offset) |
void |
setOrderByEventComparator(OrderByEventComparator orderByEventComparator) |
void |
setToLast(Processor processor)
Set as the last element of the processor chain
|
public QuerySelector(String id, io.siddhi.query.api.execution.query.selection.Selector selector, boolean currentOn, boolean expiredOn, SiddhiQueryContext siddhiQueryContext)
public void process(ComplexEventChunk complexEventChunk)
Processor
public void process(List<ComplexEventChunk> complexEventChunks)
Processor
public ComplexEventChunk execute(ComplexEventChunk complexEventChunk)
public Processor getNextProcessor()
Processor
getNextProcessor
in interface Processor
public void setNextProcessor(OutputRateLimiter outputRateLimiter)
public void setNextProcessor(Processor processor)
Processor
setNextProcessor
in interface Processor
processor
- Processor to be set as next element of processor chainpublic void setToLast(Processor processor)
Processor
public List<AttributeProcessor> getAttributeProcessorList()
public void setAttributeProcessorList(List<AttributeProcessor> attributeProcessorList, boolean containsAggregator)
public void setGroupByKeyGenerator(GroupByKeyGenerator groupByKeyGenerator)
public void setOrderByEventComparator(OrderByEventComparator orderByEventComparator)
public void setHavingConditionExecutor(ConditionExpressionExecutor havingConditionExecutor, boolean containsAggregator)
public void setBatchingEnabled(boolean batchingEnabled)
public void setEventPopulator(StateEventPopulator eventPopulator)
public void setLimit(long limit)
public void setOffset(long offset)
Copyright © 2021. All rights reserved.