本文整理汇总了Java中org.wso2.siddhi.query.api.definition.AbstractDefinition类的典型用法代码示例。如果您正苦于以下问题:Java AbstractDefinition类的具体用法?Java AbstractDefinition怎么用?Java AbstractDefinition使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
AbstractDefinition类属于org.wso2.siddhi.query.api.definition包,在下文中一共展示了AbstractDefinition类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: constructQueryEventSourceList
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
@Override
public List<QueryEventSource> constructQueryEventSourceList(
ConcurrentMap<String, AbstractDefinition> streamTableDefinitionMap,
List<QueryEventSource> queryEventSources) {
AbstractDefinition definition = streamTableDefinitionMap.get(streamId);
if (definition == null) {
throw new SourceNotExistException("Stream definition not exist! No steam defined with stream ID: " + streamId);
}
if (definition instanceof TableDefinition) {
throw new SourceNotExistException(streamId + " is not a Stream but a Table, and it cant have window");
}
streamDefinition = (StreamDefinition) definition;
queryEventSource = new QueryEventSource(streamId, streamReferenceId,
streamDefinition,
filter, transformer, window);
queryEventSources.add(queryEventSource);
return queryEventSources;
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:20,代码来源:WindowStream.java
示例2: constructEventStreamList
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
public List<QueryEventSource> constructEventStreamList(PatternElement patternElement,
ConcurrentMap<String, AbstractDefinition> streamTableDefinitionMap,
List<QueryEventSource> queryEventSources) {
if (patternElement instanceof BasicStream) {
((BasicStream) patternElement).constructQueryEventSourceList(streamTableDefinitionMap, queryEventSources);
} else if (patternElement instanceof LogicalElement) {
constructEventStreamList(((LogicalElement) patternElement).getTransformedStream1(), streamTableDefinitionMap, queryEventSources);
constructEventStreamList(((LogicalElement) patternElement).getTransformedStream2(), streamTableDefinitionMap, queryEventSources);
} else if (patternElement instanceof CountElement) {
constructEventStreamList(((CountElement) patternElement).getTransformedStream(), streamTableDefinitionMap, queryEventSources);
} else if (patternElement instanceof FollowedByElement) {
constructEventStreamList(((FollowedByElement) patternElement).getPatternElement(), streamTableDefinitionMap, queryEventSources);
constructEventStreamList(((FollowedByElement) patternElement).getFollowedByPatternElement(), streamTableDefinitionMap, queryEventSources);
} else if (patternElement instanceof PatternStream) {
((PatternStream) patternElement).constructQueryEventSourceList(streamTableDefinitionMap, queryEventSources);
}
return queryEventSources;
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:22,代码来源:PatternStream.java
示例3: constructEventStreamList
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
public List<QueryEventSource> constructEventStreamList(SequenceElement sequenceElement,
ConcurrentMap<String, AbstractDefinition> streamTableDefinitionMap,
List<QueryEventSource> queryEventSources) {
if (sequenceElement instanceof BasicStream) {
((BasicStream) sequenceElement).constructQueryEventSourceList(streamTableDefinitionMap, queryEventSources);
} else if (sequenceElement instanceof OrElement) {
constructEventStreamList(((OrElement) sequenceElement).getTransformedStream1(), streamTableDefinitionMap, queryEventSources);
constructEventStreamList(((OrElement) sequenceElement).getTransformedStream2(), streamTableDefinitionMap, queryEventSources);
} else if (sequenceElement instanceof RegexElement) {
constructEventStreamList(((RegexElement) sequenceElement).getTransformedStream(), streamTableDefinitionMap, queryEventSources);
} else if (sequenceElement instanceof NextElement) {
constructEventStreamList(((NextElement) sequenceElement).getSequenceElement(), streamTableDefinitionMap, queryEventSources);
constructEventStreamList(((NextElement) sequenceElement).getNextSequenceElement(), streamTableDefinitionMap, queryEventSources);
} else if (sequenceElement instanceof SequenceStream) {
((SequenceStream) sequenceElement).constructQueryEventSourceList(streamTableDefinitionMap, queryEventSources);
}
return queryEventSources;
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:22,代码来源:SequenceStream.java
示例4: constructQueryEventSourceList
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
@Override
public List<QueryEventSource> constructQueryEventSourceList(
ConcurrentMap<String, AbstractDefinition> streamTableDefinitionMap,
List<QueryEventSource> queryEventSources) {
definition = streamTableDefinitionMap.get(streamId);
if (definition == null) {
throw new SourceNotExistException("Definition not exist! No stream/table defined with stream ID: " + streamId);
}
if (definition instanceof TableDefinition) {
if (filter != null || transformer != null) {
throw new SourceNotExistException(streamId + " is not a Stream but a Table, and it cant have filter or transformer");
}
}
queryEventSource = new QueryEventSource(streamId, streamReferenceId,
definition,
filter, transformer, null);
queryEventSource.setCounterStream(isCounterStream);
queryEventSources.add(queryEventSource);
return queryEventSources;
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:22,代码来源:BasicStream.java
示例5: validate
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
@Override
protected void validate(List<QueryEventSource> queryEventSourceList, ConcurrentMap<String, AbstractDefinition> streamTableDefinitionMap, String streamReferenceId,
boolean processInStreamDefinition) {
AbstractDefinition definition = streamTableDefinitionMap.get(sourceId);
if (definition == null) {
throw new SourceNotExistException("Event Table with name '" + sourceId + "' not defined in Siddhi");
} else {
if (!(definition instanceof TableDefinition)) {
throw new SourceNotExistException(sourceId + " is not an Event Table");
}
}
queryEventSourceList.add(new QueryEventSource(sourceId, sourceId, definition, null, null, null));
condition.validate(queryEventSourceList, streamTableDefinitionMap, streamReferenceId, processInStreamDefinition);
queryEventSourceList.remove(queryEventSourceList.size() - 1);
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:20,代码来源:InCondition.java
示例6: validate
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
@Override
protected void validate(List<QueryEventSource> queryEventSourceList, ConcurrentMap<String, AbstractDefinition> streamTableDefinitionMap, String streamReferenceId,
boolean processInStreamDefinition) {
if (operator.equals(Operator.INSTANCE_OF)) {
if (rightExpression instanceof StringConstant) {
String dataType = ((StringConstant) rightExpression).getValue();
if (!(dataType.equalsIgnoreCase(String.class.getSimpleName()) || dataType.equalsIgnoreCase(Integer.class.getSimpleName())
|| dataType.equalsIgnoreCase(Double.class.getSimpleName()) || dataType.equalsIgnoreCase(Boolean.class.getSimpleName())
|| dataType.equalsIgnoreCase(Long.class.getSimpleName()) || dataType.equalsIgnoreCase(Float.class.getSimpleName()))) {
throw new MalformedAttributeException("\"" + dataType + "\" is not a valid attribute data type");
}
}
}
ExpressionValidator.validate(rightExpression, queryEventSourceList, streamReferenceId, processInStreamDefinition);
ExpressionValidator.validate(leftExpression, queryEventSourceList, streamReferenceId, processInStreamDefinition);
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:19,代码来源:Compare.java
示例7: init
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
@Override
protected void init(Expression[] parameters, QueryPostProcessingElement nextProcessor, AbstractDefinition streamDefinition, String elementId, boolean async, SiddhiContext siddhiContext) {
mostFrqntCount = ((IntConstant) parameters[0]).getValue();
attributeIndexes = new ArrayList<Integer>();
if (parameters.length > 1) { // by-default all the attributes will be compared
for (int i = 1; i < parameters.length; i++) {
attributeIndexes.add(streamDefinition.getAttributePosition(((Variable) parameters[i]).getAttributeName()));
}
}
if (attributeIndexes.size() == streamDefinition.getAttributeList().size()) { // if all the attributes are configured or non-configured we compare all, so we ignore this index
attributeIndexes.clear();
}
if (this.siddhiContext.isDistributedProcessingEnabled()) {
countMap = new SiddhiMapGrid<Integer>(elementId, this.siddhiContext);
map = new SiddhiMapGrid<StreamEvent>(elementId, this.siddhiContext);
} else {
countMap = new SiddhiMap<Integer>();
map = new SiddhiMap<StreamEvent>();
}
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:22,代码来源:FrequentWindowProcessor.java
示例8: init
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
@Override
protected void init(Expression[] parameters, QueryPostProcessingElement nextProcessor, AbstractDefinition streamDefinition, String elementId, boolean async, SiddhiContext siddhiContext) {
if (parameters[0] instanceof IntConstant) {
timeToKeep = ((IntConstant) parameters[0]).getValue();
} else {
timeToKeep = ((LongConstant) parameters[0]).getValue();
}
oldEventList = new ArrayList<RemoveEvent>();
if (this.siddhiContext.isDistributedProcessingEnabled()) {
newEventList = this.siddhiContext.getHazelcastInstance().getList(elementId + "-newEventList");
} else {
newEventList = new ArrayList<InEvent>();
}
if (this.siddhiContext.isDistributedProcessingEnabled()) {
window = new SchedulerSiddhiQueueGrid<StreamEvent>(elementId, this, this.siddhiContext, this.async);
} else {
window = new SchedulerSiddhiQueue<StreamEvent>(this);
}
//Ordinary scheduling
window.schedule();
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:25,代码来源:TimeBatchWindowProcessor.java
示例9: init
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
@Override
protected void init(Expression[] parameters, QueryPostProcessingElement nextProcessor, AbstractDefinition streamDefinition, String elementId, boolean async, SiddhiContext siddhiContext) {
uniqueAttributeNames = new String[parameters.length];
for (int i = 0, parametersLength = parameters.length; i < parametersLength; i++) {
uniqueAttributeNames[i] = ((Variable) parameters[i]).getAttributeName();
}
if (this.siddhiContext.isDistributedProcessingEnabled()) {
map = new SiddhiMapGrid<StreamEvent>(elementId, this.siddhiContext);
} else {
map = new SiddhiMap<StreamEvent>();
}
attributePositions = new int[uniqueAttributeNames.length];
for (int i = 0; i < uniqueAttributeNames.length; i++) {
String attributeName = uniqueAttributeNames[i];
attributePositions[i] = definition.getAttributePosition(attributeName);
}
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:20,代码来源:UniqueWindowProcessor.java
示例10: init
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
@Override
protected void init(Expression[] parameters, QueryPostProcessingElement nextProcessor, AbstractDefinition streamDefinition, String elementId, boolean async, SiddhiContext siddhiContext) {
lengthToKeep = ((IntConstant) parameters[0]).getValue();
if (this.siddhiContext.isDistributedProcessingEnabled()) {
window = new SiddhiQueueGrid<StreamEvent>(elementId, this.siddhiContext, this.async);
} else {
window = new SiddhiQueue<StreamEvent>();
}
oldEventList = new ArrayList<RemoveEvent>();
if (this.siddhiContext.isDistributedProcessingEnabled()) {
newEventList = this.siddhiContext.getHazelcastInstance().getList(elementId + "-newEventList");
} else {
newEventList = new ArrayList<InEvent>();
}
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:18,代码来源:LengthBatchWindowProcessor.java
示例11: init
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
@Override
protected void init(Expression[] parameters, QueryPostProcessingElement nextProcessor, AbstractDefinition streamDefinition, String elementId, boolean async, SiddhiContext siddhiContext) {
uniqueAttributeNames = new String[parameters.length];
for (int i = 0, parametersLength = parameters.length; i < parametersLength; i++) {
uniqueAttributeNames[i] = ((Variable) parameters[i]).getAttributeName();
}
if (this.siddhiContext.isDistributedProcessingEnabled()) {
map = new SiddhiMapGrid<StreamEvent>(elementId, this.siddhiContext);
} else {
map = new SiddhiMap<StreamEvent>();
}
attributePositions = new int[uniqueAttributeNames.length];
for (int i = 0; i < uniqueAttributeNames.length; i++) {
String attributeName = uniqueAttributeNames[i];
attributePositions[i] = definition.getAttributePosition(attributeName);
}
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:19,代码来源:FirstUniqueWindowProcessor.java
示例12: init
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
@Override
protected void init(Expression[] parameters, QueryPostProcessingElement nextProcessor, AbstractDefinition streamDefinition, String elementId, boolean async, SiddhiContext siddhiContext) {
if (parameters[1] instanceof IntConstant) {
timeToKeep = ((IntConstant) parameters[1]).getValue();
} else {
timeToKeep = ((LongConstant) parameters[1]).getValue();
}
timeStampAttributeName = ((Variable) parameters[0]).getAttributeName();
timeStampAttributePosition = definition.getAttributePosition(timeStampAttributeName);
if (this.siddhiContext.isDistributedProcessingEnabled()) {
window = new SiddhiQueueGrid<StreamEvent>(elementId, this.siddhiContext, this.async);
} else {
window = new SiddhiQueue<StreamEvent>();
}
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:17,代码来源:ExternalTimeWindowProcessor.java
示例13: parseSingleStream
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
public static QueryPartComposite parseSingleStream(Stream queryStream, QueryEventSource queryEventSource, List<QueryEventSource> queryEventSourceList, ConcurrentMap<String, AbstractDefinition> streamTableDefinitionMap,
ConcurrentMap<String, EventTable> eventTableMap, SiddhiContext siddhiContext) {
QueryPartComposite queryPartComposite = new QueryPartComposite();
SimpleHandlerProcessor simpleHandlerProcessor = new SimpleHandlerProcessor(queryEventSource,
generateFilerProcessor(queryEventSource, queryEventSourceList, streamTableDefinitionMap, eventTableMap, siddhiContext),
generateTransformProcessor(queryEventSource, queryEventSourceList, siddhiContext),
siddhiContext);
if (queryStream instanceof WindowStream) {
WindowProcessor windowProcessor = generateWindowProcessor(queryEventSource, siddhiContext, null, false);
windowProcessor.initWindow();
simpleHandlerProcessor.setNext(windowProcessor);
queryPartComposite.getPreSelectProcessingElementList().add(windowProcessor);
} else {
queryPartComposite.getPreSelectProcessingElementList().add(simpleHandlerProcessor);
}
queryPartComposite.getHandlerProcessorList().add(simpleHandlerProcessor);
return queryPartComposite;
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:22,代码来源:StreamParser.java
示例14: updateAttributeData
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
private AbstractDefinition updateAttributeData(int position, boolean processInDefinition, int i, QueryEventSource queryEventSource) {
AbstractDefinition definition;
if (processInDefinition) {
definition = queryEventSource.getInDefinition();
} else {
definition = queryEventSource.getOutDefinition();
}
streamPosition = i;
if (position > -1) { //for known positions
innerStreamPosition = position;
} else if (position == SiddhiConstants.PREV) {
innerStreamPosition = SiddhiConstants.PREV;
} else if (queryEventSource.isCounterStream()) { //to get the last event
innerStreamPosition = SiddhiConstants.LAST;
}
return definition;
}
开发者ID:redBorder,项目名称:rb-bi,代码行数:18,代码来源:VariableExpressionExecutor.java
示例15: getStreamDefinition
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
public static AbstractDefinition getStreamDefinition(String executionPlan, String streamId) {
SiddhiManager siddhiManager = null;
SiddhiAppRuntime runtime = null;
try {
siddhiManager = new SiddhiManager();
runtime = siddhiManager.createSiddhiAppRuntime(executionPlan);
Map<String, StreamDefinition> definitionMap = runtime.getStreamDefinitionMap();
if (definitionMap.containsKey(streamId)) {
return definitionMap.get(streamId);
} else {
throw new IllegalArgumentException("Unknown stream id" + streamId);
}
} finally {
if (runtime != null) {
runtime.shutdown();
}
if (siddhiManager != null) {
siddhiManager.shutdown();
}
}
}
开发者ID:haoch,项目名称:flink-siddhi,代码行数:22,代码来源:SiddhiTypeFactory.java
示例16: getTupleTypeInformation
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
public static <T extends Tuple> TypeInformation<T> getTupleTypeInformation(AbstractDefinition definition) {
int tupleSize = definition.getAttributeList().size();
StringBuilder stringBuilder = new StringBuilder();
stringBuilder.append("Tuple").append(tupleSize);
stringBuilder.append("<");
List<String> attributeTypes = new ArrayList<>();
for (Attribute attribute : definition.getAttributeList()) {
attributeTypes.add(getJavaType(attribute.getType()).getName());
}
stringBuilder.append(StringUtils.join(attributeTypes, ","));
stringBuilder.append(">");
try {
return TypeInfoParser.parse(stringBuilder.toString());
} catch (IllegalArgumentException ex) {
throw new IllegalArgumentException("Unable to parse " + stringBuilder.toString(), ex);
}
}
开发者ID:haoch,项目名称:flink-siddhi,代码行数:18,代码来源:SiddhiTypeFactory.java
示例17: getStreamDefinition
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
public static AbstractDefinition getStreamDefinition(String executionPlan, String streamId) {
SiddhiManager siddhiManager = null;
SiddhiAppRuntime runtime = null;
try {
siddhiManager = new SiddhiManager();
runtime = siddhiManager.createSiddhiAppRuntime(executionPlan);
Map<String, StreamDefinition> definitionMap = runtime.getStreamDefinitionMap();
if (definitionMap.containsKey(streamId)) {
return definitionMap.get(streamId);
} else {
throw new IllegalArgumentException("Unknown stream id" + streamId);
}
} finally {
if (runtime != null) {
runtime.shutdown();
}
if (siddhiManager != null) {
siddhiManager.shutdown();
}
}
}
开发者ID:apache,项目名称:bahir-flink,代码行数:22,代码来源:SiddhiTypeFactory.java
示例18: getTupleTypeInformation
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
public static <T extends Tuple> TypeInformation<T> getTupleTypeInformation(AbstractDefinition definition) {
int tupleSize = definition.getAttributeList().size();
StringBuilder stringBuilder = new StringBuilder();
stringBuilder.append("Tuple").append(tupleSize);
stringBuilder.append("<");
List<String> attributeTypes = new ArrayList<>();
for (Attribute attribute : definition.getAttributeList()) {
attributeTypes.add(getJavaType(attribute.getType()).getName());
}
stringBuilder.append(StringUtils.join(attributeTypes, ","));
stringBuilder.append(">");
try {
return TypeInfoParser.parse(stringBuilder.toString());
} catch (IllegalArgumentException ex) {
throw new IllegalArgumentException("Unable to parse " + stringBuilder.toString(), ex);
}
}
开发者ID:apache,项目名称:bahir-flink,代码行数:18,代码来源:SiddhiTypeFactory.java
示例19: start
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
/**
* Starts the siddhi execution plan
*
* @param siddhiManager The manager that will manage the execution plan
* @param siddhiCallback The callback to be called when the execution plan creates a new message
* @throws ExecutionPlanException
*/
public void start(SiddhiManager siddhiManager, SiddhiCallback siddhiCallback) throws ExecutionPlanException {
this.executionPlanRuntime = siddhiManager.createExecutionPlanRuntime(getFullExecutionPlan());
for (Map.Entry<String, String> entry : outputTopics.entrySet()) {
String streamName = entry.getKey();
String topic = entry.getValue();
AbstractDefinition abstractDefinition = executionPlanRuntime.getStreamDefinitionMap().get(streamName);
if (abstractDefinition != null) {
List<Attribute> attributes = abstractDefinition.getAttributeList();
StreamCallback streamCallback = siddhiCallback.getCallback(streamName, topic, attributes);
executionPlanRuntime.addCallback(streamName, streamCallback);
} else {
throw new InvalidExecutionPlanException("You specified a output that is not present on the execution plan");
}
}
executionPlanRuntime.start();
log.info("Started execution plan with id {} version {}", id, version, fullExecutionPlan);
}
开发者ID:redBorder,项目名称:cep,代码行数:29,代码来源:SiddhiPlan.java
示例20: PartitionRuntime
import org.wso2.siddhi.query.api.definition.AbstractDefinition; //导入依赖的package包/类
public PartitionRuntime(ConcurrentMap<String, AbstractDefinition> streamDefinitionMap, ConcurrentMap<String,
StreamJunction> streamJunctionMap, Partition partition, SiddhiAppContext siddhiAppContext) {
this.siddhiAppContext = siddhiAppContext;
if (partition.getPartitionTypeMap().isEmpty()) {
throw new SiddhiAppCreationException("Partition must have at least one executor. But found none.");
}
try {
Element element = AnnotationHelper.getAnnotationElement("info", "name",
partition.getAnnotations());
if (element != null) {
this.partitionId = element.getValue();
}
} catch (DuplicateAnnotationException e) {
throw new DuplicateAnnotationException(e.getMessageWithOutContext() + " for the same Query " +
partition.toString(), e, e.getQueryContextStartIndex(), e.getQueryContextEndIndex(),
siddhiAppContext.getName(), siddhiAppContext.getSiddhiAppString());
}
if (partitionId == null) {
this.partitionId = UUID.randomUUID().toString();
}
elementId = "PartitionRuntime-" + siddhiAppContext.getElementIdGenerator().createNewId();
this.partition = partition;
this.streamDefinitionMap = streamDefinitionMap;
this.streamJunctionMap = streamJunctionMap;
}
开发者ID:wso2,项目名称:siddhi,代码行数:26,代码来源:PartitionRuntime.java
注:本文中的org.wso2.siddhi.query.api.definition.AbstractDefinition类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论