Package | Description |
---|---|
io.siddhi.core.stream.input.source |
Modifier and Type | Method and Description |
---|---|
abstract void |
SourceMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder optionHolder,
List<AttributeMapping> attributeMappingList,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext)
Initialize Source-mapper
|
void |
PassThroughSourceMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder optionHolder,
List<AttributeMapping> attributeMappingList,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext) |
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 |
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 |
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) |
Copyright © 2019. All rights reserved.