public class BinarySinkMapper
extends io.siddhi.core.stream.output.sink.SinkMapper
Constructor and Description |
---|
BinarySinkMapper() |
Modifier and Type | Method and Description |
---|---|
Class[] |
getOutputEventClasses() |
String[] |
getSupportedDynamicOptions() |
void |
init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
io.siddhi.core.util.transport.OptionHolder optionHolder,
Map<String,io.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap,
io.siddhi.core.util.config.ConfigReader configReader,
io.siddhi.core.config.SiddhiAppContext siddhiAppContext) |
void |
mapAndSend(io.siddhi.core.event.Event[] events,
io.siddhi.core.util.transport.OptionHolder optionHolder,
Map<String,io.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap,
io.siddhi.core.stream.output.sink.SinkListener sinkListener) |
void |
mapAndSend(io.siddhi.core.event.Event event,
io.siddhi.core.util.transport.OptionHolder optionHolder,
Map<String,io.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap,
io.siddhi.core.stream.output.sink.SinkListener sinkListener) |
public void init(io.siddhi.query.api.definition.StreamDefinition streamDefinition, io.siddhi.core.util.transport.OptionHolder optionHolder, Map<String,io.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap, io.siddhi.core.util.config.ConfigReader configReader, io.siddhi.core.config.SiddhiAppContext siddhiAppContext)
init
in class io.siddhi.core.stream.output.sink.SinkMapper
public String[] getSupportedDynamicOptions()
getSupportedDynamicOptions
in class io.siddhi.core.stream.output.sink.SinkMapper
public Class[] getOutputEventClasses()
getOutputEventClasses
in class io.siddhi.core.stream.output.sink.SinkMapper
public void mapAndSend(io.siddhi.core.event.Event[] events, io.siddhi.core.util.transport.OptionHolder optionHolder, Map<String,io.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap, io.siddhi.core.stream.output.sink.SinkListener sinkListener)
mapAndSend
in class io.siddhi.core.stream.output.sink.SinkMapper
public void mapAndSend(io.siddhi.core.event.Event event, io.siddhi.core.util.transport.OptionHolder optionHolder, Map<String,io.siddhi.core.util.transport.TemplateBuilder> payloadTemplateBuilderMap, io.siddhi.core.stream.output.sink.SinkListener sinkListener)
mapAndSend
in class io.siddhi.core.stream.output.sink.SinkMapper
Copyright © 2022 WSO2. All rights reserved.