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() |
boolean |
isStateful() |
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 void setSiddhiAppContext(SiddhiAppContext siddhiAppContext)
public SiddhiContext getSiddhiContext()
public io.siddhi.query.api.execution.query.output.stream.OutputStream.OutputEventType getOutputEventType()
public void setOutputEventType(io.siddhi.query.api.execution.query.output.stream.OutputStream.OutputEventType outputEventType)
public LatencyTracker getLatencyTracker()
public void setLatencyTracker(LatencyTracker latencyTracker)
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)
public boolean isStateful()
Copyright © 2019. All rights reserved.