Modifier and Type | Method and Description |
---|---|
Collection<Window> |
SiddhiAppRuntime.getWindows() |
Collection<Window> |
SiddhiAppRuntimeImpl.getWindows() |
Constructor and Description |
---|
SiddhiAppRuntimeImpl(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,
ConcurrentMap<String,Trigger> triggerMap,
SiddhiAppContext siddhiAppContext,
Map<String,SiddhiAppRuntime> siddhiAppRuntimeMap) |
Modifier and Type | Method and Description |
---|---|
void |
IncrementalDataPurger.init(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
StreamEventFactory streamEventFactory,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
Boolean isProcessingOnExternalTime,
SiddhiQueryContext siddhiQueryContext,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> activeIncrementalDurations,
String timeZone,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap) |
Constructor and Description |
---|
IncrementalExecutorsInitialiser(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,Executor> incrementalExecutorMap,
boolean isDistributed,
String shardId,
SiddhiAppContext siddhiAppContext,
MetaStreamEvent metaStreamEvent,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap,
String timeZone) |
Constructor and Description |
---|
FindOnDemandQueryRuntime(Window window,
CompiledCondition compiledCondition,
String queryName,
MetaStreamEvent metaStreamEvent) |
Modifier and Type | Field and Description |
---|---|
protected Window |
InsertIntoWindowCallback.window
Window to which the events have to be inserted.
|
Modifier and Type | Method and Description |
---|---|
Window |
InsertIntoWindowCallback.getWindow()
Return the
Window associated with this callback. |
Constructor and Description |
---|
InsertIntoWindowCallback(Window window,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
String queryName) |
InsertIntoWindowEndPartitionCallback(Window window,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
String queryName) |
Constructor and Description |
---|
WindowWindowProcessor(Window window) |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<String,Window> |
SiddhiAppRuntimeBuilder.getWindowMap() |
Modifier and Type | Method and Description |
---|---|
static OutputCallback |
OutputParser.constructOutputCallback(io.siddhi.query.api.execution.query.output.stream.OutputStream outStream,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
Map<String,Table> tableMap,
Map<String,Window> eventWindowMap,
boolean convertToStreamEvent,
SiddhiQueryContext siddhiQueryContext) |
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 StreamRuntime |
InputStreamParser.parse(io.siddhi.query.api.execution.query.input.stream.InputStream inputStream,
io.siddhi.query.api.execution.query.Query query,
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,
List<VariableExpressionExecutor> executors,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext)
Parse an InputStream returning corresponding StreamRuntime
|
static OnDemandQueryRuntime |
OnDemandQueryParser.parse(io.siddhi.query.api.execution.query.OnDemandQuery onDemandQuery,
String onDemandQueryString,
SiddhiAppContext siddhiAppContext,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap) |
static QueryRuntimeImpl |
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 StreamRuntime |
JoinInputStreamParser.parseInputStream(io.siddhi.query.api.execution.query.input.stream.JoinInputStream joinInputStream,
io.siddhi.query.api.execution.query.Query query,
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,
List<VariableExpressionExecutor> executors,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
static void |
DefinitionParserHelper.addWindow(io.siddhi.query.api.definition.WindowDefinition windowDefinition,
ConcurrentMap<String,Window> eventWindowMap,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
void |
Window.init(Map<String,Table> tableMap,
Map<String,Window> eventWindowMap,
String windowName,
boolean findToBeExecuted)
Initialize the WindowEvent table by creating
WindowProcessor to handle the events. |
Copyright © 2021. All rights reserved.