Java AbstractDefinition类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了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；未经允许，请勿转载。

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java SHA224类代码示例发布时间：2022-05-22

Java ParamTree类代码示例发布时间：2022-05-22

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18085|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9615|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8147|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8530|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8432|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9344|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8396|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7833|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8387|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7380|2022-11-06

客服电话

电子邮件

Java AbstractDefinition类代码示例

示例1: constructQueryEventSourceList

示例2: constructEventStreamList

示例3: constructEventStreamList

示例4: constructQueryEventSourceList

示例5: validate

示例6: validate

示例7: init

示例8: init

示例9: init

示例10: init

示例11: init

示例12: init

示例13: parseSingleStream

示例14: updateAttributeData

示例15: getStreamDefinition

示例16: getTupleTypeInformation

示例17: getStreamDefinition

示例18: getTupleTypeInformation

示例19: start

示例20: PartitionRuntime

请发表评论

全部评论

上一篇：

下一篇：

GitbookIO/gitbook:

juleswhite/mobile-cloud-asgn1

kyamagu/matlab-json: Use official API: h

墙壁眼睛膝盖

OpenKinect/libfreenect: Drivers and libr

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053