Constructor and Description |
---|
SiddhiAppRuntime(Map<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> tableDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> aggregationDefinitionMap,
InputManager inputManager,
Map<String,QueryRuntime> queryProcessorMap,
Map<String,StreamJunction> streamJunctionMap,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
ConcurrentMap<String,AggregationRuntime> aggregationMap,
Map<String,List<Source>> sourceMap,
Map<String,List<Sink>> sinkMap,
Map<String,PartitionRuntime> partitionMap,
SiddhiAppContext siddhiAppContext,
Map<String,SiddhiAppRuntime> siddhiAppRuntimeMap) |
Constructor and Description |
---|
IncrementalAggregationProcessor(AggregationRuntime aggregationRuntime,
List<ExpressionExecutor> incomingExpressionExecutors,
MetaStreamEvent processedMetaStreamEvent,
LatencyTracker latencyTrackerInsert,
ThroughputTracker throughputTrackerInsert,
SiddhiAppContext siddhiAppContext) |
RecreateInMemoryData(List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap,
SiddhiAppContext siddhiAppContext,
MetaStreamEvent metaStreamEvent,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap,
String shardId,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMapForPartitions) |
Modifier and Type | Method and Description |
---|---|
SiddhiAppContext |
SiddhiQueryContext.getSiddhiAppContext() |
Modifier and Type | Method and Description |
---|---|
void |
SiddhiQueryContext.setSiddhiAppContext(SiddhiAppContext siddhiAppContext) |
Constructor and Description |
---|
SiddhiQueryContext(SiddhiAppContext siddhiAppContext,
String queryName) |
SiddhiQueryContext(SiddhiAppContext siddhiAppContext,
String queryName,
String partitionId) |
Constructor and Description |
---|
SiddhiDebugger(SiddhiAppContext siddhiAppContext)
Create a new SiddhiDebugger instance for the given
SiddhiAppContext . |
Constructor and Description |
---|
SiddhiAppCreationException(String message,
io.siddhi.query.api.SiddhiElement siddhiElement,
SiddhiAppContext siddhiAppContext) |
SiddhiAppCreationException(String message,
Throwable throwable,
int[] queryContextStartIndex,
int[] queryContextEndIndex,
SiddhiAppContext siddhiAppContext) |
Constructor and Description |
---|
PartitionRuntime(ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
io.siddhi.query.api.execution.partition.Partition partition,
int partitionIndex,
SiddhiAppContext siddhiAppContext) |
PartitionStreamReceiver(SiddhiAppContext siddhiAppContext,
MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.StreamDefinition streamDefinition,
List<PartitionExecutor> partitionExecutors,
PartitionRuntime partitionRuntime) |
Constructor and Description |
---|
EntryValveExecutor(SiddhiAppContext siddhiAppContext) |
EntryValveProcessor(SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
void |
QueryCallback.setContext(SiddhiAppContext siddhiAppContext) |
Constructor and Description |
---|
StreamJunction(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
ExecutorService executorService,
int bufferSize,
StreamJunction faultStreamJunction,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Field and Description |
---|---|
protected SiddhiAppContext |
InputHandler.siddhiAppContext |
Constructor and Description |
---|
InputEntryValve(SiddhiAppContext siddhiAppContext,
InputProcessor inputProcessor) |
InputHandler(String streamId,
int streamIndex,
InputProcessor inputProcessor,
SiddhiAppContext siddhiAppContext) |
InputManager(SiddhiAppContext siddhiAppContext,
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
ConcurrentMap<String,StreamJunction> streamJunctionMap) |
Modifier and Type | Method and Description |
---|---|
abstract StateFactory<S> |
Source.init(SourceEventListener sourceEventListener,
OptionHolder optionHolder,
String[] requestedTransportPropertyNames,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext)
To initialize the source.
|
StateFactory<State> |
InMemorySource.init(SourceEventListener sourceEventListener,
OptionHolder optionHolder,
String[] requestedTransportPropertyNames,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext) |
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 |
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) |
abstract StateFactory |
SourceHandler.init(String siddhiAppName,
SourceSyncCallback sourceSyncCallback,
io.siddhi.query.api.definition.StreamDefinition streamDefinition,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
void |
StreamCallback.setContext(SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
void |
SinkCallback.init(SiddhiAppContext siddhiAppContext) |
protected StateFactory<State> |
InMemorySink.init(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
OptionHolder optionHolder,
ConfigReader sinkConfigReader,
SiddhiAppContext siddhiAppContext) |
protected StateFactory<State> |
LogSink.init(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
OptionHolder optionHolder,
ConfigReader sinkConfigReader,
SiddhiAppContext siddhiAppContext) |
protected abstract StateFactory<S> |
Sink.init(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
OptionHolder optionHolder,
ConfigReader sinkConfigReader,
SiddhiAppContext siddhiAppContext)
Will be called for initialing the
Sink |
void |
PassThroughSinkMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
ConfigReader mapperConfigReader,
SiddhiAppContext siddhiAppContext) |
abstract void |
SinkMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
ConfigReader mapperConfigReader,
SiddhiAppContext siddhiAppContext)
Initialize the mapper and the mapping configurations.
|
void |
Sink.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
String type,
OptionHolder transportOptionHolder,
ConfigReader sinkConfigReader,
SinkMapper sinkMapper,
String mapType,
OptionHolder mapOptionHolder,
SinkHandler sinkHandler,
List<io.siddhi.query.api.annotation.Element> payloadElementList,
ConfigReader mapperConfigReader,
Map<String,String> deploymentProperties,
SiddhiAppContext siddhiAppContext) |
void |
SinkMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
String type,
OptionHolder mapOptionHolder,
List<io.siddhi.query.api.annotation.Element> unmappedPayloadList,
Sink sink,
ConfigReader mapperConfigReader,
LatencyTracker mapperLatencyTracker,
SiddhiAppContext siddhiAppContext) |
void |
Sink.initOnlyTransport(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder transportOptionHolder,
ConfigReader sinkConfigReader,
String type,
DistributedTransport.ConnectionCallback connectionCallback,
Map<String,String> deploymentProperties,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Field and Description |
---|---|
protected SiddhiAppContext |
DistributedTransport.siddhiAppContext |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<State> |
DistributedTransport.init(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
OptionHolder optionHolder,
ConfigReader sinkConfigReader,
SiddhiAppContext siddhiAppContext)
Will be called for initialing the
Sink |
void |
DistributedTransport.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
String type,
OptionHolder transportOptionHolder,
ConfigReader sinkConfigReader,
SinkMapper sinkMapper,
String mapType,
OptionHolder mapOptionHolder,
SinkHandler sinkHandler,
List<io.siddhi.query.api.annotation.Element> payloadElementList,
ConfigReader mapperConfigReader,
SiddhiAppContext siddhiAppContext,
List<OptionHolder> destinationOptionHolders,
io.siddhi.query.api.annotation.Annotation sinkAnnotation,
DistributionStrategy strategy,
String[] supportedDynamicOptions,
Map<String,String> deploymentProperties,
List<Map<String,String>> destinationDeploymentProperties)
This is method contains the additional parameters which require to initialize distributed transport
|
abstract void |
DistributedTransport.initTransport(OptionHolder sinkOptionHolder,
List<OptionHolder> destinationOptionHolders,
Map<String,String> deploymentProperties,
List<Map<String,String>> destinationDeploymentProperties,
io.siddhi.query.api.annotation.Annotation sinkAnnotation,
ConfigReader sinkConfigReader,
DistributionStrategy strategy,
String type,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
Table.init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
void |
InMemoryTable.init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
void |
Table.initTable(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
Constructor and Description |
---|
IndexEventHolder(StreamEventFactory tableStreamEventFactory,
StreamEventConverter eventConverter,
PrimaryKeyReferenceHolder[] primaryKeyReferenceHolders,
boolean isPrimaryNumeric,
Map<String,Integer> indexMetaData,
io.siddhi.query.api.definition.AbstractDefinition tableDefinition,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
RecordTableHandler.init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
RecordTableHandlerCallback recordTableHandlerCallback,
SiddhiAppContext siddhiAppContext) |
void |
AbstractRecordTable.init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
Modifier and Type | Method and Description |
---|---|
void |
StartTrigger.init(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition,
SiddhiAppContext siddhiAppContext,
StreamJunction streamJunction) |
void |
CronTrigger.init(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition,
SiddhiAppContext siddhiAppContext,
StreamJunction streamJunction) |
void |
Trigger.init(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition,
SiddhiAppContext siddhiAppContext,
StreamJunction streamJunction) |
void |
PeriodicTrigger.init(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition,
SiddhiAppContext siddhiAppContext,
StreamJunction streamJunction) |
Modifier and Type | Method and Description |
---|---|
static String |
ExceptionUtil.getMessageWithContext(Throwable throwable,
SiddhiAppContext siddhiAppContext) |
static void |
ExceptionUtil.populateQueryContext(Throwable t,
io.siddhi.query.api.SiddhiElement siddhiElement,
SiddhiAppContext siddhiAppContext) |
Constructor and Description |
---|
SiddhiAppRuntimeBuilder(SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
static WindowProcessorExtensionHolder |
WindowProcessorExtensionHolder.getInstance(SiddhiAppContext siddhiAppContext) |
static AttributeAggregatorExtensionHolder |
AttributeAggregatorExtensionHolder.getInstance(SiddhiAppContext siddhiAppContext) |
static SinkMapperExecutorExtensionHolder |
SinkMapperExecutorExtensionHolder.getInstance(SiddhiAppContext siddhiAppContext) |
static SourceExecutorExtensionHolder |
SourceExecutorExtensionHolder.getInstance(SiddhiAppContext siddhiAppContext) |
static TableExtensionHolder |
TableExtensionHolder.getInstance(SiddhiAppContext siddhiAppContext) |
static SinkExecutorExtensionHolder |
SinkExecutorExtensionHolder.getInstance(SiddhiAppContext siddhiAppContext) |
static IncrementalAttributeAggregatorExtensionHolder |
IncrementalAttributeAggregatorExtensionHolder.getInstance(SiddhiAppContext siddhiAppContext) |
static StreamProcessorExtensionHolder |
StreamProcessorExtensionHolder.getInstance(SiddhiAppContext siddhiAppContext) |
static FunctionExecutorExtensionHolder |
FunctionExecutorExtensionHolder.getInstance(SiddhiAppContext siddhiAppContext) |
static ScriptExtensionHolder |
ScriptExtensionHolder.getInstance(SiddhiAppContext siddhiAppContext) |
static StreamFunctionProcessorExtensionHolder |
StreamFunctionProcessorExtensionHolder.getInstance(SiddhiAppContext siddhiAppContext) |
static SourceMapperExecutorExtensionHolder |
SourceMapperExecutorExtensionHolder.getInstance(SiddhiAppContext siddhiAppContext) |
static DistributionStrategyExtensionHolder |
DistributionStrategyExtensionHolder.getInstance(SiddhiAppContext siddhiAppContext) |
Constructor and Description |
---|
AbstractExtensionHolder(Class clazz,
SiddhiAppContext siddhiAppContext) |
ScriptExtensionHolder(SiddhiAppContext siddhiAppContext) |
TableExtensionHolder(SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
static EventHolder |
EventHolderPasser.parse(io.siddhi.query.api.definition.AbstractDefinition tableDefinition,
StreamEventFactory tableStreamEventFactory,
SiddhiAppContext siddhiAppContext) |
static AggregationRuntime |
AggregationParser.parse(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
SiddhiAppContext siddhiAppContext,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> tableDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> aggregationDefinitionMap,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap,
SiddhiAppRuntimeBuilder siddhiAppRuntimeBuilder) |
static QueryRuntime |
QueryParser.parse(io.siddhi.query.api.execution.query.Query query,
SiddhiAppContext siddhiAppContext,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> tableDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> aggregationDefinitionMap,
Map<String,Table> tableMap,
Map<String,AggregationRuntime> aggregationMap,
Map<String,Window> windowMap,
LockSynchronizer lockSynchronizer,
String queryIndex,
boolean partitioned,
String partitionId)
Parse a query and return corresponding QueryRuntime.
|
static PartitionRuntime |
PartitionParser.parse(SiddhiAppRuntimeBuilder siddhiAppRuntimeBuilder,
io.siddhi.query.api.execution.partition.Partition partition,
SiddhiAppContext siddhiAppContext,
int queryIndex,
int partitionIndex) |
static StoreQueryRuntime |
StoreQueryParser.parse(io.siddhi.query.api.execution.query.StoreQuery storeQuery,
SiddhiAppContext siddhiAppContext,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap) |
Modifier and Type | Method and Description |
---|---|
static void |
DefinitionParserHelper.addEventSink(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
ConcurrentMap<String,List<Sink>> eventSinkMap,
SiddhiAppContext siddhiAppContext) |
static void |
DefinitionParserHelper.addEventSource(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
ConcurrentMap<String,List<Source>> eventSourceMap,
SiddhiAppContext siddhiAppContext) |
static void |
DefinitionParserHelper.addEventTrigger(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition,
ConcurrentMap<String,Trigger> eventTriggerMap,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
SiddhiAppContext siddhiAppContext) |
static void |
DefinitionParserHelper.addFunction(SiddhiAppContext siddhiAppContext,
io.siddhi.query.api.definition.FunctionDefinition functionDefinition) |
static void |
DefinitionParserHelper.addStreamJunction(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
SiddhiAppContext siddhiAppContext) |
static void |
DefinitionParserHelper.addTable(io.siddhi.query.api.definition.TableDefinition tableDefinition,
ConcurrentMap<String,Table> tableMap,
SiddhiAppContext siddhiAppContext) |
static void |
DefinitionParserHelper.addWindow(io.siddhi.query.api.definition.WindowDefinition windowDefinition,
ConcurrentMap<String,Window> eventWindowMap,
SiddhiAppContext siddhiAppContext) |
static LatencyTracker |
QueryParserHelper.createLatencyTracker(SiddhiAppContext siddhiAppContext,
String name,
String type,
String function) |
static ThroughputTracker |
QueryParserHelper.createThroughputTracker(SiddhiAppContext siddhiAppContext,
String name,
String type,
String function) |
static void |
QueryParserHelper.registerMemoryUsageTracking(String name,
Object value,
String metricInfixQueries,
SiddhiAppContext siddhiAppContext,
MemoryUsageTracker memoryUsageTracker) |
Modifier and Type | Method and Description |
---|---|
static PersistenceReference |
PersistenceHelper.persist(byte[] serializeObj,
SiddhiAppContext siddhiAppContext) |
static PersistenceReference |
PersistenceHelper.persist(IncrementalSnapshot serializeObj,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
static Object |
ByteSerializer.byteToObject(byte[] bytes,
SiddhiAppContext siddhiAppContext) |
static byte[] |
ByteSerializer.objectToByte(Object obj,
SiddhiAppContext siddhiAppContext) |
Constructor and Description |
---|
SnapshotService(SiddhiAppContext siddhiAppContext) |
Constructor and Description |
---|
TimestampGeneratorImpl(SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
void |
MultiClientDistributedSink.initTransport(OptionHolder sinkOptionHolder,
List<OptionHolder> destinationOptionHolders,
Map<String,String> deploymentProperties,
List<Map<String,String>> destinationDeploymentProperties,
io.siddhi.query.api.annotation.Annotation sinkAnnotation,
ConfigReader sinkConfigReader,
DistributionStrategy strategy,
String type,
SiddhiAppContext siddhiAppContext) |
void |
SingleClientDistributedSink.initTransport(OptionHolder sinkOptionHolder,
List<OptionHolder> destinationOptionHolders,
Map<String,String> deploymentProperties,
List<Map<String,String>> destinationDeploymentProperties,
io.siddhi.query.api.annotation.Annotation sinkAnnotation,
ConfigReader sinkConfigReader,
DistributionStrategy strategy,
String type,
SiddhiAppContext siddhiAppContext) |
Constructor and Description |
---|
Window(io.siddhi.query.api.definition.WindowDefinition windowDefinition,
SiddhiAppContext siddhiAppContext)
Construct a Window object.
|
Copyright © 2019. All rights reserved.