public class BinarySinkMapper
extends org.wso2.siddhi.core.stream.output.sink.SinkMapper
Constructor and Description |
---|
BinarySinkMapper() |
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 configReader,
org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext) |
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) |
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 configReader, org.wso2.siddhi.core.config.SiddhiAppContext siddhiAppContext)
init
in class org.wso2.siddhi.core.stream.output.sink.SinkMapper
public String[] getSupportedDynamicOptions()
getSupportedDynamicOptions
in class org.wso2.siddhi.core.stream.output.sink.SinkMapper
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, Map<String,org.wso2.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap, 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, Map<String,org.wso2.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap, 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.