org.wso2.extension.siddhi.execution.env

Class GetYAMLPropertyFunction

java.lang.Object

io.siddhi.core.executor.function.FunctionExecutor

org.wso2.extension.siddhi.execution.env.GetYAMLPropertyFunction

All Implemented Interfaces:

io.siddhi.core.executor.ExpressionExecutor

public class GetYAMLPropertyFunction
extends io.siddhi.core.executor.function.FunctionExecutor

Siddhi Function getYAMLProperty to read property values from deployment.yaml.

Field Summary

Fields inherited from class io.siddhi.core.executor.function.FunctionExecutor

attributeExpressionExecutors, functionId, processingMode, siddhiQueryContext

Constructor Summary

Constructors

Constructor and Description
GetYAMLPropertyFunction()

Method Summary

Modifier and Type	Method and Description
protected Object	execute(Object[] data, io.siddhi.core.util.snapshot.state.State state) The main execution method which will be called upon event arrival when there are more than one function parameter.
protected Object	execute(Object data, io.siddhi.core.util.snapshot.state.State state) The main execution method which will be called upon event arrival when there are zero or one function parameter.
io.siddhi.query.api.definition.Attribute.Type	getReturnType() This will be called only once and this can be used to acquire required resources for the processing element.
protected io.siddhi.core.util.snapshot.state.StateFactory	init(io.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors, io.siddhi.core.util.config.ConfigReader reader, io.siddhi.core.config.SiddhiQueryContext siddhiQueryContext) The initialization method for TheFun, this method will be called before the other methods.

Methods inherited from class io.siddhi.core.executor.function.FunctionExecutor

execute, execute, execute, initExecutor

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GetYAMLPropertyFunction

public GetYAMLPropertyFunction()

Method Detail

init

protected io.siddhi.core.util.snapshot.state.StateFactory init(io.siddhi.core.executor.ExpressionExecutor[] attributeExpressionExecutors,
                                                               io.siddhi.core.util.config.ConfigReader reader,
                                                               io.siddhi.core.config.SiddhiQueryContext siddhiQueryContext)

The initialization method for TheFun, this method will be called before the other methods.

Specified by:

init in class io.siddhi.core.executor.function.FunctionExecutor

Parameters:

attributeExpressionExecutors - the executors of each function parameter.

siddhiQueryContext - the context of the siddhi query.

execute

protected Object execute(Object[] data,
                         io.siddhi.core.util.snapshot.state.State state)

The main execution method which will be called upon event arrival when there are more than one function parameter.

Specified by:

execute in class io.siddhi.core.executor.function.FunctionExecutor

Parameters:

data - the runtime values of function parameters.

Returns:

the function result.

execute

protected Object execute(Object data,
                         io.siddhi.core.util.snapshot.state.State state)

The main execution method which will be called upon event arrival when there are zero or one function parameter.

Specified by:

execute in class io.siddhi.core.executor.function.FunctionExecutor

Parameters:

data - null if the function parameter count is zero or runtime data value of the function parameter.

Returns:

the function result.

getReturnType

public io.siddhi.query.api.definition.Attribute.Type getReturnType()

This will be called only once and this can be used to acquire required resources for the processing element. This will be called after initializing the system and before starting to process the events.