public class PartitionRuntimeImpl extends Object implements PartitionRuntime
Modifier and Type | Class and Description |
---|---|
class |
PartitionRuntimeImpl.PartitionState
State of partition
|
Constructor and Description |
---|
PartitionRuntimeImpl(ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
io.siddhi.query.api.execution.partition.Partition partition,
int partitionIndex,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
void |
addInnerpartitionStreamReceiverStreamJunction(String key,
StreamJunction streamJunction) |
void |
addPartitionReceiver(QueryRuntimeImpl queryRuntime,
List<VariableExpressionExecutor> executors,
MetaStateEvent metaEvent) |
void |
addQuery(QueryRuntimeImpl metaQueryRuntime) |
ConcurrentMap<String,StreamJunction> |
getInnerPartitionStreamReceiverStreamJunctionMap() |
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> |
getLocalStreamDefinitionMap() |
ConcurrentMap<String,StreamJunction> |
getLocalStreamJunctionMap() |
Set<String> |
getPartitionKeys() |
String |
getPartitionName() |
Collection<QueryRuntime> |
getQueries() |
void |
init() |
void |
initPartition() |
void |
setMemoryUsageTracker(MemoryUsageTracker memoryUsageTracker) |
public PartitionRuntimeImpl(ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap, ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap, ConcurrentMap<String,StreamJunction> streamJunctionMap, io.siddhi.query.api.execution.partition.Partition partition, int partitionIndex, SiddhiAppContext siddhiAppContext)
public void addQuery(QueryRuntimeImpl metaQueryRuntime)
public void addPartitionReceiver(QueryRuntimeImpl queryRuntime, List<VariableExpressionExecutor> executors, MetaStateEvent metaEvent)
public void addInnerpartitionStreamReceiverStreamJunction(String key, StreamJunction streamJunction)
public ConcurrentMap<String,StreamJunction> getInnerPartitionStreamReceiverStreamJunctionMap()
public void init()
public String getPartitionName()
getPartitionName
in interface PartitionRuntime
public ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> getLocalStreamDefinitionMap()
getLocalStreamDefinitionMap
in interface PartitionRuntime
public ConcurrentMap<String,StreamJunction> getLocalStreamJunctionMap()
public void setMemoryUsageTracker(MemoryUsageTracker memoryUsageTracker)
public void initPartition()
public Collection<QueryRuntime> getQueries()
getQueries
in interface PartitionRuntime
Copyright © 2019. All rights reserved.