public class IncrementalShouldUpdateFunctionExecutor extends FunctionExecutor<io.siddhi.core.executor.incremental.IncrementalShouldUpdateFunctionExecutor.FunctionState>
attributeExpressionExecutors, functionId, processingMode, siddhiQueryContext
Constructor and Description |
---|
IncrementalShouldUpdateFunctionExecutor() |
Modifier and Type | Method and Description |
---|---|
protected Object |
execute(Object[] data,
io.siddhi.core.executor.incremental.IncrementalShouldUpdateFunctionExecutor.FunctionState state)
The main execution method which will be called upon event arrival
when there are more then one function parameter
|
protected Object |
execute(Object data,
io.siddhi.core.executor.incremental.IncrementalShouldUpdateFunctionExecutor.FunctionState state)
return true/false based on timestamp values
|
io.siddhi.query.api.definition.Attribute.Type |
getReturnType() |
protected StateFactory<io.siddhi.core.executor.incremental.IncrementalShouldUpdateFunctionExecutor.FunctionState> |
init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor, this method will be called before the other methods
|
execute, execute, execute, initExecutor
public IncrementalShouldUpdateFunctionExecutor()
protected StateFactory<io.siddhi.core.executor.incremental.IncrementalShouldUpdateFunctionExecutor.FunctionState> init(ExpressionExecutor[] attributeExpressionExecutors, ConfigReader configReader, SiddhiQueryContext siddhiQueryContext)
FunctionExecutor
init
in class FunctionExecutor<io.siddhi.core.executor.incremental.IncrementalShouldUpdateFunctionExecutor.FunctionState>
attributeExpressionExecutors
- are the executors of each function parametersconfigReader
- This hold the FunctionExecutor
extensions configuration reader.siddhiQueryContext
- the context of the siddhi queryprotected Object execute(Object[] data, io.siddhi.core.executor.incremental.IncrementalShouldUpdateFunctionExecutor.FunctionState state)
FunctionExecutor
execute
in class FunctionExecutor<io.siddhi.core.executor.incremental.IncrementalShouldUpdateFunctionExecutor.FunctionState>
data
- the runtime values of function parametersstate
- current query stateprotected Object execute(Object data, io.siddhi.core.executor.incremental.IncrementalShouldUpdateFunctionExecutor.FunctionState state)
execute
in class FunctionExecutor<io.siddhi.core.executor.incremental.IncrementalShouldUpdateFunctionExecutor.FunctionState>
data
- of Long typestate
- function statepublic io.siddhi.query.api.definition.Attribute.Type getReturnType()
Copyright © 2019. All rights reserved.