io.siddhi.extension.map.json.sourcemapper

Class JsonSourceMapper

java.lang.Object

io.siddhi.core.stream.input.source.SourceMapper

io.siddhi.extension.map.json.sourcemapper.JsonSourceMapper

All Implemented Interfaces:

io.siddhi.core.stream.input.source.SourceEventListener

public class JsonSourceMapper
extends io.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.

Field Summary

Fields inherited from class io.siddhi.core.stream.input.source.SourceMapper

sourceOptionHolder, sourceType

Constructor Summary

Constructors

Constructor and Description
JsonSourceMapper()

Method Summary

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

Methods inherited from class io.siddhi.core.stream.input.source.SourceMapper

getEventCount, getHandler, getStreamDefinition, init, onEvent, onEvent, onEvent, 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(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
                 io.siddhi.core.util.transport.OptionHolder optionHolder,
                 List<io.siddhi.core.stream.input.source.AttributeMapping> attributeMappingList,
                 io.siddhi.core.util.config.ConfigReader configReader,
                 io.siddhi.core.config.SiddhiAppContext siddhiAppContext)

Specified by:

init in class io.siddhi.core.stream.input.source.SourceMapper

mapAndProcess

protected void mapAndProcess(Object eventObject,
                             io.siddhi.core.stream.input.source.InputEventHandler inputEventHandler)
                      throws io.siddhi.core.exception.MappingFailedException,
                             InterruptedException

Specified by:

mapAndProcess in class io.siddhi.core.stream.input.source.SourceMapper

Throws:

io.siddhi.core.exception.MappingFailedException

InterruptedException

allowNullInTransportProperties

protected boolean allowNullInTransportProperties()

Specified by:

allowNullInTransportProperties in class io.siddhi.core.stream.input.source.SourceMapper

getSupportedInputEventClasses

public Class[] getSupportedInputEventClasses()

Specified by:

getSupportedInputEventClasses in class io.siddhi.core.stream.input.source.SourceMapper