public class QueryRuntime extends Object implements MemoryCalculable, ExternalReferencedHolder
Constructor and Description |
---|
QueryRuntime(io.siddhi.query.api.execution.query.Query query,
StreamRuntime streamRuntime,
QuerySelector selector,
OutputRateLimiter outputRateLimiter,
OutputCallback outputCallback,
MetaComplexEvent metaComplexEvent,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
void |
addCallback(QueryCallback callback) |
List<String> |
getInputStreamId() |
MetaComplexEvent |
getMetaComplexEvent() |
OutputCallback |
getOutputCallback() |
OutputRateLimiter |
getOutputRateManager() |
io.siddhi.query.api.definition.StreamDefinition |
getOutputStreamDefinition() |
io.siddhi.query.api.execution.query.Query |
getQuery() |
String |
getQueryId() |
QuerySelector |
getSelector() |
SiddhiQueryContext |
getSiddhiQueryContext() |
StreamRuntime |
getStreamRuntime() |
void |
init() |
void |
initPartition() |
boolean |
isFromLocalStream() |
boolean |
isToLocalStream() |
void |
setToLocalStream(boolean toLocalStream) |
void |
start()
This will be called only once and this can be used to acquire
required resources for the processing element.
|
void |
stop()
This will be called only once and this can be used to release
the acquired resources for processing.
|
public QueryRuntime(io.siddhi.query.api.execution.query.Query query, StreamRuntime streamRuntime, QuerySelector selector, OutputRateLimiter outputRateLimiter, OutputCallback outputCallback, MetaComplexEvent metaComplexEvent, SiddhiQueryContext siddhiQueryContext)
public String getQueryId()
public void addCallback(QueryCallback callback)
public OutputRateLimiter getOutputRateManager()
public io.siddhi.query.api.definition.StreamDefinition getOutputStreamDefinition()
public boolean isToLocalStream()
public void setToLocalStream(boolean toLocalStream)
public boolean isFromLocalStream()
public SiddhiQueryContext getSiddhiQueryContext()
public StreamRuntime getStreamRuntime()
public MetaComplexEvent getMetaComplexEvent()
public io.siddhi.query.api.execution.query.Query getQuery()
public OutputCallback getOutputCallback()
public void init()
public QuerySelector getSelector()
public void initPartition()
public void start()
ExternalReferencedHolder
start
in interface ExternalReferencedHolder
public void stop()
ExternalReferencedHolder
stop
in interface ExternalReferencedHolder
Copyright © 2019. All rights reserved.