public class SiddhiQueryContext extends Object
SiddhiApp
.Constructor and Description |
---|
SiddhiQueryContext(SiddhiAppContext siddhiAppContext,
String queryName) |
SiddhiQueryContext(SiddhiAppContext siddhiAppContext,
String queryName,
String partitionId) |
Modifier and Type | Method and Description |
---|---|
String |
generateNewId() |
StateHolder |
generateStateHolder(String name,
boolean groupBy,
StateFactory stateFactory) |
StateHolder |
generateStateHolder(String name,
boolean groupBy,
StateFactory stateFactory,
boolean unSafe) |
LatencyTracker |
getLatencyTracker() |
String |
getName() |
io.siddhi.query.api.execution.query.output.stream.OutputStream.OutputEventType |
getOutputEventType() |
SiddhiAppContext |
getSiddhiAppContext() |
SiddhiContext |
getSiddhiContext() |
boolean |
isPartitioned() |
void |
setLatencyTracker(LatencyTracker latencyTracker) |
void |
setName(String name) |
void |
setOutputEventType(io.siddhi.query.api.execution.query.output.stream.OutputStream.OutputEventType outputEventType) |
void |
setPartitioned(boolean partitionable) |
void |
setSiddhiAppContext(SiddhiAppContext siddhiAppContext) |
public SiddhiQueryContext(SiddhiAppContext siddhiAppContext, String queryName)
public SiddhiQueryContext(SiddhiAppContext siddhiAppContext, String queryName, String partitionId)
public String getName()
public void setName(String name)
public SiddhiAppContext getSiddhiAppContext()
public SiddhiContext getSiddhiContext()
public void setSiddhiAppContext(SiddhiAppContext siddhiAppContext)
public void setOutputEventType(io.siddhi.query.api.execution.query.output.stream.OutputStream.OutputEventType outputEventType)
public io.siddhi.query.api.execution.query.output.stream.OutputStream.OutputEventType getOutputEventType()
public void setLatencyTracker(LatencyTracker latencyTracker)
public LatencyTracker getLatencyTracker()
public boolean isPartitioned()
public void setPartitioned(boolean partitionable)
public String generateNewId()
public StateHolder generateStateHolder(String name, boolean groupBy, StateFactory stateFactory)
public StateHolder generateStateHolder(String name, boolean groupBy, StateFactory stateFactory, boolean unSafe)
Copyright © 2019. All rights reserved.