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

Query.getInputStream介绍

暂无

代码示例

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

List<String> streamIdsList;
if (executionElement instanceof Query) {
  streamIdsList =  ((Query) executionElement).getInputStream().getUniqueStreamIds();
  for (String streamId : streamIdsList) {
    if (inMemoryAggregationIds.contains(streamId)) {
    streamIdsList =  ((Query) innerPartitionElement).getInputStream().getUniqueStreamIds();
    for (String streamId : streamIdsList) {
      if (inMemoryAggregationIds.contains(streamId)) {

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

InputStream inputStream = ((Query) executionElement).getInputStream();
Selector selector = ((Query) executionElement).getSelector();
Map<String, SingleInputStream> queryLevelAliasToStreamMapping = new HashMap<>();

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

String queryString) throws StormQueryConstructionException {
if (parallel != -1) {    //if not a partition
  if (!(query.getInputStream() instanceof BasicSingleInputStream)) {      //if window/join/pattern query
    if (parallel > 1) {
      throw new StormQueryConstructionException("Error in deploying query: " + queryString + " Parallelism has " +

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

if (inputStreamDataHolder.isInnerGroupStream()) {
  for (ExecutionElement element : siddhiApp.getExecutionElementList()) {
    if (element instanceof Partition && ((Partition) element).getQueryList().get(0).getInputStream()
        .getAllStreamIds().contains(inputStreamDataHolder.getStreamName()) &&
        siddhiQueryGroup.getParallelism() > SiddhiTopologyCreatorConstants.DEFAULT_PARALLEL) {

代码示例来源：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();
    for (Query query : partition.getQueryList()) {
      for (String id : query.getInputStream().getUniqueStreamIds()) {
        if (!id.contains("#")) {  //if not an inner stream
          inputDefinitionIds.add(id);

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

InputStream inputStream = ((Query) executionElement).getInputStream();
Selector selector = ((Query) executionElement).getSelector();
Map<String, SingleInputStream> queryLevelAliasToStreamMapping = new HashMap<>();

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

String execGroupName = siddhiQueryGroup.getName();
StreamDataHolder streamDataHolder;
InputStream inputStream = (executionElement).getInputStream();
Map<String, InputStreamDataHolder> inputStreamDataHolderMap = new HashMap<>();

代码示例来源：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.stream.processor.core

List<Query> partitionStream = ((Partition) executionElement).getQueryList();
for (Query query : partitionStream) {
  for (String inputStreamId : query.getInputStream().getUniqueStreamIds()) {
    SiddhiAppElements siddhiAppElements = new SiddhiAppElements();

代码示例来源：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;
}