abstract void |
SinkMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
ConfigReader mapperConfigReader,
SiddhiAppContext siddhiAppContext)
Initialize the mapper and the mapping configurations.
|
void |
PassThroughSinkMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
ConfigReader mapperConfigReader,
SiddhiAppContext siddhiAppContext) |
abstract void |
SinkMapper.mapAndSend(Event[] events,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener)
Called to map the events and send them to SinkListener for publishing
|
void |
PassThroughSinkMapper.mapAndSend(Event[] events,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener) |
abstract void |
SinkMapper.mapAndSend(Event event,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener)
Called to map the event and send it to SinkListener for publishing
|
void |
PassThroughSinkMapper.mapAndSend(Event event,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener) |