本文整理了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
暂无
代码示例来源: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;
}
内容来源于网络,如有侵权,请联系作者删除!