public class PassThroughSourceMapper extends SourceMapper
sourceOptionHolder, sourceType
Constructor and Description |
---|
PassThroughSourceMapper() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
allowNullInTransportProperties()
Method used by
SourceMapper to determine on how to handle transport properties with null values. |
Class[] |
getSupportedInputEventClasses()
Support classes that the source-mapper can consume for mapping processing (used for validation purposes)
|
void |
init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder optionHolder,
List<AttributeMapping> attributeMappingList,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext)
Initialize Source-mapper
|
protected void |
mapAndProcess(Object eventObject,
InputEventHandler inputEventHandler)
Method to map the incoming event and as pass that via inputEventHandler to process further.
|
getHandler, getStreamDefinition, init, onEvent, onEvent, onEvent, onEvent, setInputHandler
public void init(io.siddhi.query.api.definition.StreamDefinition streamDefinition, OptionHolder optionHolder, List<AttributeMapping> attributeMappingList, ConfigReader configReader, SiddhiAppContext siddhiAppContext)
SourceMapper
init
in class SourceMapper
streamDefinition
- Associated output stream definitionoptionHolder
- Mapper option holderattributeMappingList
- Custom attribute mapping for source-mappingconfigReader
- System configuration readersiddhiAppContext
- Siddhi application contextpublic Class[] getSupportedInputEventClasses()
SourceMapper
getSupportedInputEventClasses
in class SourceMapper
protected void mapAndProcess(Object eventObject, InputEventHandler inputEventHandler) throws InterruptedException
SourceMapper
mapAndProcess
in class SourceMapper
eventObject
- Incoming event ObjectinputEventHandler
- Handler to pass the converted Siddhi Event for processingInterruptedException
- Throws InterruptedExceptionprotected boolean allowNullInTransportProperties()
SourceMapper
SourceMapper
to determine on how to handle transport properties with null values. If
this returns 'false' then SourceMapper
will drop any event/s with null transport
property values. If this returns
'true' then SourceMapper
will send events even though they contains null transport properties.
This method will be called after init().allowNullInTransportProperties
in class SourceMapper
SourceMapper
should allow or drop events when transport properties are null.Copyright © 2019. All rights reserved.