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

All Implemented Interfaces:

org.wso2.siddhi.core.util.snapshot.Snapshotable

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
String[]	getSupportedDynamicOptions()
void	init(org.wso2.siddhi.query.api.definition.StreamDefinition streamDefinition, org.wso2.siddhi.core.util.transport.OptionHolder optionHolder, org.wso2.siddhi.core.util.transport.TemplateBuilder payloadTemplateBuilder, org.wso2.siddhi.core.util.config.ConfigReader mapperConfigReader) Initialize the mapper and the mapping configurations.
void	mapAndSend(org.wso2.siddhi.core.event.Event[] events, org.wso2.siddhi.core.util.transport.OptionHolder optionHolder, org.wso2.siddhi.core.util.transport.TemplateBuilder payloadTemplateBuilder, org.wso2.siddhi.core.stream.output.sink.SinkListener sinkListener, org.wso2.siddhi.core.util.transport.DynamicOptions dynamicOptions)
void	mapAndSend(org.wso2.siddhi.core.event.Event event, org.wso2.siddhi.core.util.transport.OptionHolder optionHolder, org.wso2.siddhi.core.util.transport.TemplateBuilder payloadTemplateBuilder, org.wso2.siddhi.core.stream.output.sink.SinkListener sinkListener, org.wso2.siddhi.core.util.transport.DynamicOptions dynamicOptions)

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

currentState, getElementId, getType, init, mapAndSend, mapAndSend, restoreState, 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

init

public void init(org.wso2.siddhi.query.api.definition.StreamDefinition streamDefinition,
                 org.wso2.siddhi.core.util.transport.OptionHolder optionHolder,
                 org.wso2.siddhi.core.util.transport.TemplateBuilder payloadTemplateBuilder,
                 org.wso2.siddhi.core.util.config.ConfigReader mapperConfigReader)

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

payloadTemplateBuilder - Unmapped payload for reference

mapAndSend

public void mapAndSend(org.wso2.siddhi.core.event.Event[] events,
                       org.wso2.siddhi.core.util.transport.OptionHolder optionHolder,
                       org.wso2.siddhi.core.util.transport.TemplateBuilder payloadTemplateBuilder,
                       org.wso2.siddhi.core.stream.output.sink.SinkListener sinkListener,
                       org.wso2.siddhi.core.util.transport.DynamicOptions dynamicOptions)
                throws org.wso2.siddhi.core.exception.ConnectionUnavailableException

Specified by:

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

Throws:

org.wso2.siddhi.core.exception.ConnectionUnavailableException

mapAndSend

public void mapAndSend(org.wso2.siddhi.core.event.Event event,
                       org.wso2.siddhi.core.util.transport.OptionHolder optionHolder,
                       org.wso2.siddhi.core.util.transport.TemplateBuilder payloadTemplateBuilder,
                       org.wso2.siddhi.core.stream.output.sink.SinkListener sinkListener,
                       org.wso2.siddhi.core.util.transport.DynamicOptions dynamicOptions)
                throws org.wso2.siddhi.core.exception.ConnectionUnavailableException

Specified by:

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

Throws:

org.wso2.siddhi.core.exception.ConnectionUnavailableException