io.siddhi.extension.map.csv.sourcemapper

Class CSVSourceMapper

java.lang.Object

io.siddhi.core.stream.input.source.SourceMapper

io.siddhi.extension.map.csv.sourcemapper.CSVSourceMapper

All Implemented Interfaces:

io.siddhi.core.stream.input.source.SourceEventListener

public class CSVSourceMapper
extends io.siddhi.core.stream.input.source.SourceMapper

This mapper converts CSV string input to ComplexEventChunk.

Constructor Summary

Constructors

Constructor and Description
CSVSourceMapper()

Method Summary

Modifier and Type	Method and Description
protected boolean	allowNullInTransportProperties()
Class[]	getSupportedInputEventClasses() Returns the list of classes which this source can output.
void	init(io.siddhi.query.api.definition.StreamDefinition streamDefinition, io.siddhi.core.util.transport.OptionHolder optionHolder, List<io.siddhi.core.stream.input.source.AttributeMapping> attributeMappingList, io.siddhi.core.util.config.ConfigReader configReader, io.siddhi.core.config.SiddhiAppContext siddhiAppContext) The initialization method for SourceMapper.
protected void	mapAndProcess(Object eventObject, io.siddhi.core.stream.input.source.InputEventHandler inputEventHandler) Method to map the incoming event and as pass that via inputEventHandler to process further.

Methods inherited from class io.siddhi.core.stream.input.source.SourceMapper

getHandler, getStreamDefinition, init, onEvent, onEvent, setInputHandler

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CSVSourceMapper

public CSVSourceMapper()

Method Detail

init

public void init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
                 io.siddhi.core.util.transport.OptionHolder optionHolder,
                 List<io.siddhi.core.stream.input.source.AttributeMapping> attributeMappingList,
                 io.siddhi.core.util.config.ConfigReader configReader,
                 io.siddhi.core.config.SiddhiAppContext siddhiAppContext)

The initialization method for SourceMapper.

Specified by:

init in class io.siddhi.core.stream.input.source.SourceMapper

Parameters:

streamDefinition - Associated output stream definition

optionHolder - Option holder containing static configuration related to the SourceMapper

attributeMappingList - Custom attribute mapping for source-mapping

configReader - to read the SourceMapper related system configuration.

siddhiAppContext - the context of the SiddhiApp used to get siddhi

getSupportedInputEventClasses

public Class[] getSupportedInputEventClasses()

Returns the list of classes which this source can output.

Specified by:

getSupportedInputEventClasses in class io.siddhi.core.stream.input.source.SourceMapper

Returns:

String Array of classes that will be output by the source.

mapAndProcess

protected void mapAndProcess(Object eventObject,
                             io.siddhi.core.stream.input.source.InputEventHandler inputEventHandler)
                      throws InterruptedException

Method to map the incoming event and as pass that via inputEventHandler to process further.

Specified by:

mapAndProcess in class io.siddhi.core.stream.input.source.SourceMapper

Parameters:

eventObject - Incoming event Object based on the supported event class imported by the extensions.

inputEventHandler - Handler to pass the converted Siddhi Event for processing

Throws:

InterruptedException - if it does not throw the exception immediately due to streaming

allowNullInTransportProperties

protected boolean allowNullInTransportProperties()

Specified by:

allowNullInTransportProperties in class io.siddhi.core.stream.input.source.SourceMapper