Package | Description |
---|---|
io.siddhi.core.stream.input.source |
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,
OptionHolder sourceOptionHolder,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext) |
abstract StateFactory |
SourceHandler.init(String siddhiAppName,
SourceSyncCallback sourceSyncCallback,
io.siddhi.query.api.definition.StreamDefinition streamDefinition,
SiddhiAppContext siddhiAppContext) |
Copyright © 2021. All rights reserved.