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

Query.getSelector介绍

暂无

代码示例

代码示例来源：origin: org.apache.eagle/eagle-policy-base

field.setAccessible(true);
Query query = (Query) field.get(callback);
List<OutputAttribute> list = query.getSelector().getSelectionList();
for (OutputAttribute output : list) {
  outputFields.add(output.getRename());

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

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

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

Selector selector = ((Query) executionElement).getSelector();
Map<String, SingleInputStream> queryLevelAliasToStreamMapping = 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

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.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;
}