org.wso2.extension.siddhi.map.json.sinkmapper

Class JsonSinkMapper

java.lang.Object

org.wso2.siddhi.core.stream.output.sink.SinkMapper

org.wso2.extension.siddhi.map.json.sinkmapper.JsonSinkMapper

public class JsonSinkMapper
extends org.wso2.siddhi.core.stream.output.sink.SinkMapper

Mapper class to convert a Siddhi message to a JSON message. User can provide a JSON template or else we will be using a predefined JSON message format. In some instances coding best practices have been compensated for performance concerns.

Constructor Summary

Constructors

Constructor and Description
JsonSinkMapper()

Method Summary

Modifier and Type	Method and Description
Class[]	getOutputEventClasses()
String[]	getSupportedDynamicOptions()
void	init(org.wso2.siddhi.query.api.definition.StreamDefinition streamDefinition, org.wso2.siddhi.core.util.transport.OptionHolder optionHolder, Map<String,org.wso2.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap, org.wso2.siddhi.core.util.config.ConfigReader mapperConfigReader, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext) Initialize the mapper and the mapping configurations.
void	mapAndSend(org.wso2.siddhi.core.event.Event[] events, org.wso2.siddhi.core.util.transport.OptionHolder optionHolder, Map<String,org.wso2.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap, org.wso2.siddhi.core.stream.output.sink.SinkListener sinkListener)
void	mapAndSend(org.wso2.siddhi.core.event.Event event, org.wso2.siddhi.core.util.transport.OptionHolder optionHolder, Map<String,org.wso2.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap, org.wso2.siddhi.core.stream.output.sink.SinkListener sinkListener)

Methods inherited from class org.wso2.siddhi.core.stream.output.sink.SinkMapper

getType, init, setGroupDeterminer

Methods inherited from class java.lang.Object

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

Constructor Detail

JsonSinkMapper

public JsonSinkMapper()

Method Detail

getSupportedDynamicOptions

public String[] getSupportedDynamicOptions()

Specified by:

getSupportedDynamicOptions in class org.wso2.siddhi.core.stream.output.sink.SinkMapper

getOutputEventClasses

public Class[] getOutputEventClasses()

Specified by:

getOutputEventClasses in class org.wso2.siddhi.core.stream.output.sink.SinkMapper

init

public void init(org.wso2.siddhi.query.api.definition.StreamDefinition streamDefinition,
                 org.wso2.siddhi.core.util.transport.OptionHolder optionHolder,
                 Map<String,org.wso2.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap,
                 org.wso2.siddhi.core.util.config.ConfigReader mapperConfigReader,
                 org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)

Initialize the mapper and the mapping configurations.

Specified by:

init in class org.wso2.siddhi.core.stream.output.sink.SinkMapper

Parameters:

streamDefinition - The stream definition

optionHolder - Option holder containing static and dynamic options

payloadTemplateBuilderMap - Unmapped list of payloads for reference

mapAndSend

public void mapAndSend(org.wso2.siddhi.core.event.Event[] events,
                       org.wso2.siddhi.core.util.transport.OptionHolder optionHolder,
                       Map<String,org.wso2.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap,
                       org.wso2.siddhi.core.stream.output.sink.SinkListener sinkListener)

Specified by:

mapAndSend in class org.wso2.siddhi.core.stream.output.sink.SinkMapper

mapAndSend

public void mapAndSend(org.wso2.siddhi.core.event.Event event,
                       org.wso2.siddhi.core.util.transport.OptionHolder optionHolder,
                       Map<String,org.wso2.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap,
                       org.wso2.siddhi.core.stream.output.sink.SinkListener sinkListener)

Specified by:

mapAndSend in class org.wso2.siddhi.core.stream.output.sink.SinkMapper