org.wso2.extension.siddhi.map.json.sourcemapper

Class JsonSourceMapper

java.lang.Object

org.wso2.siddhi.core.stream.input.source.SourceMapper

org.wso2.extension.siddhi.map.json.sourcemapper.JsonSourceMapper

All Implemented Interfaces:

org.wso2.siddhi.core.stream.input.source.SourceEventListener

public class JsonSourceMapper
extends org.wso2.siddhi.core.stream.input.source.SourceMapper

This mapper converts JSON string input to ComplexEventChunk. This extension accepts optional json path expressions to select specific attributes from the stream.

Constructor Summary

Constructors

Constructor and Description
JsonSourceMapper()

Method Summary

Modifier and Type	Method and Description
protected boolean	allowNullInTransportProperties()
Class[]	getSupportedInputEventClasses()
void	init(org.wso2.siddhi.query.api.definition.StreamDefinition streamDefinition, org.wso2.siddhi.core.util.transport.OptionHolder optionHolder, List<org.wso2.siddhi.core.stream.input.source.AttributeMapping> list, org.wso2.siddhi.core.util.config.ConfigReader configReader, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
protected void	mapAndProcess(Object eventObject, org.wso2.siddhi.core.stream.input.source.InputEventHandler inputEventHandler)

Methods inherited from class org.wso2.siddhi.core.stream.input.source.SourceMapper

getHandler, getStreamDefinition, init, onEvent, setInputHandler

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonSourceMapper

public JsonSourceMapper()

Method Detail

init

public void init(org.wso2.siddhi.query.api.definition.StreamDefinition streamDefinition,
                 org.wso2.siddhi.core.util.transport.OptionHolder optionHolder,
                 List<org.wso2.siddhi.core.stream.input.source.AttributeMapping> list,
                 org.wso2.siddhi.core.util.config.ConfigReader configReader,
                 org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)

Specified by:

init in class org.wso2.siddhi.core.stream.input.source.SourceMapper

mapAndProcess

protected void mapAndProcess(Object eventObject,
                             org.wso2.siddhi.core.stream.input.source.InputEventHandler inputEventHandler)
                      throws InterruptedException

Specified by:

mapAndProcess in class org.wso2.siddhi.core.stream.input.source.SourceMapper

Throws:

InterruptedException

allowNullInTransportProperties

protected boolean allowNullInTransportProperties()

Specified by:

allowNullInTransportProperties in class org.wso2.siddhi.core.stream.input.source.SourceMapper

getSupportedInputEventClasses

public Class[] getSupportedInputEventClasses()

Specified by:

getSupportedInputEventClasses in class org.wso2.siddhi.core.stream.input.source.SourceMapper