public class StreamPartitioner extends Object
Constructor and Description |
---|
StreamPartitioner(io.siddhi.query.api.execution.query.input.stream.InputStream inputStream,
io.siddhi.query.api.execution.partition.Partition partition,
MetaStateEvent metaEvent,
List<VariableExpressionExecutor> executors,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
List<List<PartitionExecutor>> |
getPartitionExecutorLists() |
public StreamPartitioner(io.siddhi.query.api.execution.query.input.stream.InputStream inputStream, io.siddhi.query.api.execution.partition.Partition partition, MetaStateEvent metaEvent, List<VariableExpressionExecutor> executors, SiddhiQueryContext siddhiQueryContext)
public List<List<PartitionExecutor>> getPartitionExecutorLists()
Copyright © 2019. All rights reserved.