public class PartitionRuntime extends Object
Modifier and Type | Class and Description |
---|---|
class |
PartitionRuntime.PartitionState
State of partition
|
Constructor and Description |
---|
PartitionRuntime(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(QueryRuntime queryRuntime,
List<VariableExpressionExecutor> executors,
MetaStateEvent metaEvent) |
void |
addQuery(QueryRuntime metaQueryRuntime) |
ConcurrentMap<String,StreamJunction> |
getInnerPartitionStreamReceiverStreamJunctionMap() |
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> |
getLocalStreamDefinitionMap() |
ConcurrentMap<String,StreamJunction> |
getLocalStreamJunctionMap() |
Set<String> |
getPartitionKeys() |
String |
getPartitionName() |
void |
init() |
void |
initPartition() |
void |
setMemoryUsageTracker(MemoryUsageTracker memoryUsageTracker) |
public PartitionRuntime(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(QueryRuntime metaQueryRuntime)
public void addPartitionReceiver(QueryRuntime queryRuntime, List<VariableExpressionExecutor> executors, MetaStateEvent metaEvent)
public void addInnerpartitionStreamReceiverStreamJunction(String key, StreamJunction streamJunction)
public ConcurrentMap<String,StreamJunction> getInnerPartitionStreamReceiverStreamJunctionMap()
public void init()
public String getPartitionName()
public ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> getLocalStreamDefinitionMap()
public ConcurrentMap<String,StreamJunction> getLocalStreamJunctionMap()
public void setMemoryUsageTracker(MemoryUsageTracker memoryUsageTracker)
public void initPartition()
Copyright © 2019. All rights reserved.