org.wso2.siddhi.query.api.execution.query.Query.getOutputStream()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(5.5k)|赞(0)|评价(0)|浏览(142)

本文整理了Java中org.wso2.siddhi.query.api.execution.query.Query.getOutputStream方法的一些代码示例,展示了Query.getOutputStream的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Query.getOutputStream方法的具体详情如下:
包路径:org.wso2.siddhi.query.api.execution.query.Query
类名称:Query
方法名:getOutputStream

Query.getOutputStream介绍

暂无

代码示例

代码示例来源:origin: wso2/siddhi

public AnonymousInputStream(Query query) {
  super("Anonymous-" + UUID.randomUUID());
  if (query.getOutputStream() != null && !(query.getOutputStream() instanceof ReturnStream)) {
    throw new SiddhiAppValidationException("OutputStream of the query is not on type Return!",
        query.getOutputStream().getQueryContextStartIndex(),
        query.getOutputStream().getQueryContextEndIndex());
  }
  this.query = query;
}

代码示例来源:origin: org.wso2.siddhi/siddhi-query-api

public AnonymousInputStream(Query query) {
  super("Anonymous-" + UUID.randomUUID());
  if (query.getOutputStream() != null && !(query.getOutputStream() instanceof ReturnStream)) {
    throw new SiddhiAppValidationException("OutputStream of the query is not on type Return!",
        query.getOutputStream().getQueryContextStartIndex(),
        query.getOutputStream().getQueryContextEndIndex());
  }
  this.query = query;
}

代码示例来源:origin: haoch/flink-siddhi

OutputStream outputStream = ((Query) executionElement).getOutputStream();
outputStreams.put(outputStream.getId(), selector.getSelectionList());

代码示例来源:origin: org.wso2.carbon.event-processing/org.wso2.carbon.event.processor.core

public void addExecutionElement(ExecutionElementInfoHolder infoHolder) throws StormQueryConstructionException {
  if (infoHolder.getExecutionElement() instanceof Query) {
    inputDefinitionIds.addAll(((Query) infoHolder.getExecutionElement()).getInputStream().getUniqueStreamIds());
    outputDefinitionIds.add(((Query) infoHolder.getExecutionElement()).getOutputStream().getId());
  } else {
    Partition partition = (Partition) infoHolder.getExecutionElement();
      outputDefinitionIds.add(query.getOutputStream().getId());

代码示例来源:origin: apache/eagle

OutputStream outputStream = ((Query) executionElement).getOutputStream();
  effectiveOutputStreams.put(outputStream.getId(), convertOutputStreamColumns(selector.getSelectionList()));
} else {

代码示例来源:origin: org.wso2.carbon.analytics/org.wso2.carbon.stream.processor.core

siddhiAppElements.setOutputStreamId(query.getOutputStream().getId());
siddhiAppElements.setPartitionQuery(getDefinition(query, siddhiAppString));
loadQueryName(executionElement.getAnnotations(), siddhiAppElements);
loadInputData(siddhiApp, siddhiAppRuntime, inputStreamId, siddhiAppString, siddhiAppElements);
String outputStreamId = query.getOutputStream().getId();
loadOutputData(siddhiApp, siddhiAppRuntime, outputStreamId, siddhiAppString, siddhiAppElements);
loadFunctionData(siddhiApp, query.getSelector().getSelectionList(), siddhiAppElements, siddhiAppString);

代码示例来源:origin: org.wso2.carbon.analytics/org.wso2.carbon.stream.processor.core

/**
 * Load all the elements of query
 */
private void loadQueryExecutionElements(SiddhiApp siddhiApp, SiddhiAppRuntime siddhiAppRuntime, ExecutionElement
    executionElement, String siddhiAppString, List<SiddhiAppElements> listOfSiddhiAppElements) {
  for (String inputStreamId : (((Query) executionElement).getInputStream()
      .getUniqueStreamIds())) {
    SiddhiAppElements siddhiAppElements = new SiddhiAppElements();
    siddhiAppElements.setInputStreamId(inputStreamId);
    loadInputData(siddhiApp, siddhiAppRuntime, inputStreamId, siddhiAppString, siddhiAppElements);
    String outPutStreamId = ((Query) executionElement)
        .getOutputStream().getId();
    siddhiAppElements.setOutputStreamId(outPutStreamId);
    loadOutputData(siddhiApp, siddhiAppRuntime, outPutStreamId, siddhiAppString, siddhiAppElements);
    loadFunctionData(siddhiApp, ((Query) executionElement).getSelector
        ().getSelectionList(), siddhiAppElements, siddhiAppString);
    loadQueryName(executionElement.getAnnotations(), siddhiAppElements);
    Query query = (Query) executionElement;
    siddhiAppElements.setQuery(getDefinition(query, siddhiAppString));
    listOfSiddhiAppElements.add(siddhiAppElements);
  }
}

代码示例来源:origin: org.wso2.carbon.analytics/org.wso2.carbon.sp.jobmanager.core

siddhiQueryGroup.addInputStreams(getInputStreamHolderInfo((Query) executionElement,
    siddhiQueryGroup, true));
String outputStreamId = ((Query) executionElement).getOutputStream().getId();
siddhiQueryGroup.addOutputStream(outputStreamId, getOutputStreamHolderInfo(outputStreamId, parallelism,
        queryGroupName));
  String outputStreamId = query.getOutputStream().getId();
  siddhiQueryGroup.addOutputStream(outputStreamId, getOutputStreamHolderInfo(outputStreamId,
      parallelism, queryGroupName));

代码示例来源:origin: org.wso2.carbon.analytics/org.wso2.carbon.siddhi.editor.core

/**
 * Generates a QueryConfig object with the given Siddhi Query object
 * @param query                 Siddhi Query object
 * @return                      QueryConfig object
 */
public QueryConfig generateQueryConfig(Query query)
    throws DesignGenerationException {
  QueryConfig queryConfig = new QueryConfig();
  queryConfig.setQueryInput(generateInput(query.getInputStream()));
  Selector selector = query.getSelector();
  queryConfig.setSelect(generateSelect(selector));
  queryConfig.setGroupBy(generateGroupBy(selector.getGroupByList()));
  queryConfig.setOrderBy(generateOrderBy(selector.getOrderByList()));
  queryConfig.setHaving(generateHaving(selector.getHavingExpression()));
  queryConfig.setLimit(generateLimit(selector.getLimit()));
  queryConfig.setQueryOutput(generateOutput(query.getOutputStream()));
  queryConfig.setOutputRateLimit(generateOutputRateLimit(query.getOutputRate()));
  queryConfig.setAnnotationList(generateAnnotationList(query.getAnnotations()));
  queryConfig.setQueryName(generateQueryName(query.getAnnotations()));
  preserveAndBindCodeSegment(query, queryConfig);
  return queryConfig;
}

相关文章