public class DefinitionParserHelper extends Object
Constructor and Description |
---|
DefinitionParserHelper() |
Modifier and Type | Method and Description |
---|---|
static void |
addEventSink(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
StreamJunction streamJunction,
ConcurrentMap<String,List<Sink>> eventSinkMap,
SiddhiAppContext siddhiAppContext) |
static void |
addEventSource(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
ConcurrentMap<String,List<Source>> eventSourceMap,
SiddhiAppContext siddhiAppContext) |
static void |
addEventTrigger(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition,
ConcurrentMap<String,Trigger> eventTriggerMap,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
SiddhiAppContext siddhiAppContext) |
static void |
addFunction(SiddhiAppContext siddhiAppContext,
io.siddhi.query.api.definition.FunctionDefinition functionDefinition) |
static void |
addStreamJunction(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
SiddhiAppContext siddhiAppContext) |
static void |
addTable(io.siddhi.query.api.definition.TableDefinition tableDefinition,
ConcurrentMap<String,Table> tableMap,
SiddhiAppContext siddhiAppContext) |
static void |
addWindow(io.siddhi.query.api.definition.WindowDefinition windowDefinition,
ConcurrentMap<String,Window> eventWindowMap,
SiddhiAppContext siddhiAppContext) |
static io.siddhi.query.api.extension.Extension |
constructExtension(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
String typeName,
String typeValue,
io.siddhi.query.api.annotation.Annotation annotation,
String defaultNamespace) |
static void |
validateDefinition(io.siddhi.query.api.definition.AbstractDefinition definition,
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> tableDefinitionMap,
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap,
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> aggregationDefinitionMap) |
static void |
validateDefinition(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition) |
static void |
validateOutputStream(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
io.siddhi.query.api.definition.AbstractDefinition existingStream) |
public static void validateDefinition(io.siddhi.query.api.definition.AbstractDefinition definition, ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap, ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> tableDefinitionMap, ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap, ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> aggregationDefinitionMap)
public static void addStreamJunction(io.siddhi.query.api.definition.StreamDefinition streamDefinition, ConcurrentMap<String,StreamJunction> streamJunctionMap, SiddhiAppContext siddhiAppContext)
public static void validateOutputStream(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition, io.siddhi.query.api.definition.AbstractDefinition existingStream)
public static void addTable(io.siddhi.query.api.definition.TableDefinition tableDefinition, ConcurrentMap<String,Table> tableMap, SiddhiAppContext siddhiAppContext)
public static void addWindow(io.siddhi.query.api.definition.WindowDefinition windowDefinition, ConcurrentMap<String,Window> eventWindowMap, SiddhiAppContext siddhiAppContext)
public static void addFunction(SiddhiAppContext siddhiAppContext, io.siddhi.query.api.definition.FunctionDefinition functionDefinition)
public static void validateDefinition(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition)
public static void addEventTrigger(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition, ConcurrentMap<String,Trigger> eventTriggerMap, ConcurrentMap<String,StreamJunction> streamJunctionMap, SiddhiAppContext siddhiAppContext)
public static void addEventSource(io.siddhi.query.api.definition.StreamDefinition streamDefinition, ConcurrentMap<String,List<Source>> eventSourceMap, SiddhiAppContext siddhiAppContext)
public static void addEventSink(io.siddhi.query.api.definition.StreamDefinition streamDefinition, StreamJunction streamJunction, ConcurrentMap<String,List<Sink>> eventSinkMap, SiddhiAppContext siddhiAppContext)
Copyright © 2019. All rights reserved.