Package | Description |
---|---|
io.siddhi.core.stream.input.source |
Modifier and Type | Method and Description |
---|---|
abstract SourceHandler |
SourceHandlerManager.generateSourceHandler() |
SourceHandler |
SourceMapper.getHandler() |
Modifier and Type | Method and Description |
---|---|
HashMap<String,SourceHandler> |
SourceHandlerManager.getRegsiteredSourceHandlers() |
Modifier and Type | Method and Description |
---|---|
void |
SourceMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
String mapType,
OptionHolder mapOptionHolder,
List<AttributeMapping> attributeMappings,
String sourceType,
SourceSyncCallback sourceSyncCallback,
List<AttributeMapping> transportMappings,
SourceHandler sourceHandler,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext) |
void |
Source.init(String sourceType,
OptionHolder transportOptionHolder,
SourceMapper sourceMapper,
String[] transportPropertyNames,
ConfigReader configReader,
String mapType,
OptionHolder mapOptionHolder,
List<AttributeMapping> attributeMappings,
List<AttributeMapping> transportMappings,
ConfigReader mapperConfigReader,
SourceHandler sourceHandler,
io.siddhi.query.api.definition.StreamDefinition streamDefinition,
Map<String,String> deploymentProperties,
SiddhiAppContext siddhiAppContext) |
void |
SourceHandlerManager.registerSourceHandler(String elementId,
SourceHandler sourceHandler) |
Copyright © 2019. All rights reserved.