public class TextSinkMapper
extends org.wso2.siddhi.core.stream.output.sink.SinkMapper
Constructor and Description |
---|
TextSinkMapper() |
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,
org.wso2.siddhi.core.util.transport.TemplateBuilder payloadTemplateBuilder,
org.wso2.siddhi.core.util.config.ConfigReader mapperConfigReader,
org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
Initialize the mapper and the mapping configurations
* @param streamDefinition The stream definition
|
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) |
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) |
public String[] getSupportedDynamicOptions()
getSupportedDynamicOptions
in class org.wso2.siddhi.core.stream.output.sink.SinkMapper
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, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
init
in class org.wso2.siddhi.core.stream.output.sink.SinkMapper
optionHolder
- Unmapped dynamic optionspayloadTemplateBuilder
- mapperConfigReader
- siddhiAppContext
- public Class[] getOutputEventClasses()
getOutputEventClasses
in class org.wso2.siddhi.core.stream.output.sink.SinkMapper
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)
mapAndSend
in class org.wso2.siddhi.core.stream.output.sink.SinkMapper
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)
mapAndSend
in class org.wso2.siddhi.core.stream.output.sink.SinkMapper
Copyright © 2017 WSO2. All rights reserved.