public class TextSinkMapper
extends org.wso2.siddhi.core.stream.output.sink.SinkMapper
Constructor and Description |
---|
TextSinkMapper() |
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) |
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)
init
in class org.wso2.siddhi.core.stream.output.sink.SinkMapper
streamDefinition
- The stream definitionoptionHolder
- Unmapped dynamic optionspayloadTemplateBuilder
- mapperConfigReader
- 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
mapAndSend
in class org.wso2.siddhi.core.stream.output.sink.SinkMapper
org.wso2.siddhi.core.exception.ConnectionUnavailableException
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
mapAndSend
in class org.wso2.siddhi.core.stream.output.sink.SinkMapper
org.wso2.siddhi.core.exception.ConnectionUnavailableException
Copyright © 2017 WSO2. All rights reserved.