public class PassThroughSinkMapper extends SinkMapper
SinkMapper
representing pass-through scenario where no mapping is done and
Event
s are send directly to transports.sinkOptionHolder, sinkType
Constructor and Description |
---|
PassThroughSinkMapper() |
Modifier and Type | Method and Description |
---|---|
Class[] |
getOutputEventClasses()
Get produced event class types
|
String[] |
getSupportedDynamicOptions()
Supported dynamic options by the mapper
|
void |
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 |
mapAndSend(Event[] events,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener)
Called to map the events and send them to
SinkListener for publishing |
void |
mapAndSend(Event event,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener)
Called to map the event and send it to
SinkListener for publishing |
buildMapperTemplate, getType, init, setGroupDeterminer
public String[] getSupportedDynamicOptions()
SinkMapper
getSupportedDynamicOptions
in class SinkMapper
public void init(io.siddhi.query.api.definition.StreamDefinition streamDefinition, OptionHolder optionHolder, Map<String,TemplateBuilder> payloadTemplateBuilderMap, ConfigReader mapperConfigReader, SiddhiAppContext siddhiAppContext)
SinkMapper
init
in class SinkMapper
streamDefinition
- The stream definitionoptionHolder
- Option holder containing static and dynamic options related to the mapperpayloadTemplateBuilderMap
- Un mapped payloads for referencemapperConfigReader
- System configuration reader for Sink-mapper.siddhiAppContext
- Siddhi Application Contextpublic Class[] getOutputEventClasses()
SinkMapper
getOutputEventClasses
in class SinkMapper
public void mapAndSend(Event[] events, OptionHolder optionHolder, Map<String,TemplateBuilder> payloadTemplateBuilderMap, SinkListener sinkListener)
SinkMapper
SinkListener
for publishingmapAndSend
in class SinkMapper
events
- Event
s that need to be mappedoptionHolder
- Option holder containing static and dynamic options related to the mapperpayloadTemplateBuilderMap
- To build the message payloads based on the given templatessinkListener
- SinkListener
that will be called with the mapped eventspublic void mapAndSend(Event event, OptionHolder optionHolder, Map<String,TemplateBuilder> payloadTemplateBuilderMap, SinkListener sinkListener)
SinkMapper
SinkListener
for publishingmapAndSend
in class SinkMapper
event
- Event
that need to be mappedoptionHolder
- Option holder containing static and dynamic options related to the mapperpayloadTemplateBuilderMap
- To build the message payloads based on the given templatessinkListener
- SinkListener
that will be called with the mapped eventCopyright © 2021. All rights reserved.