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
void	init(org.wso2.siddhi.query.api.definition.StreamDefinition streamDefinition, org.wso2.siddhi.core.util.transport.OptionHolder optionHolder, List<org.wso2.siddhi.core.stream.AttributeMapping> attributeMappingList, org.wso2.siddhi.core.util.config.ConfigReader configReader)
protected void	mapAndProcess(Object eventObject, org.wso2.siddhi.core.stream.input.InputEventHandler inputEventHandler)

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

getInputHandler, getStreamDefinition, init, onEvent, setInputEventHandler

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.AttributeMapping> attributeMappingList,
                 org.wso2.siddhi.core.util.config.ConfigReader configReader)

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.InputEventHandler inputEventHandler)
                      throws InterruptedException

Specified by:

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

Throws:

InterruptedException