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 |
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 ComplexEventChunk execute(ComplexEventChunk complexEventChunk)
public Processor getNextProcessor()
Processor
getNextProcessor
in interface Processor
public void setNextProcessor(Processor processor)
Processor
setNextProcessor
in interface Processor
processor
- Processor to be set as next element of processor chainpublic void setNextProcessor(OutputRateLimiter outputRateLimiter)
public 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 © 2019. All rights reserved.