public class PartitionStreamReceiver extends Object implements StreamJunction.Receiver
StreamJunction.Receiver
implementation to pump events into partitions. This will send the event
to the matching partition.Constructor and Description |
---|
PartitionStreamReceiver(SiddhiAppContext siddhiAppContext,
MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.StreamDefinition streamDefinition,
List<PartitionExecutor> partitionExecutors,
PartitionRuntime partitionRuntime) |
Modifier and Type | Method and Description |
---|---|
void |
addStreamJunction(List<QueryRuntime> queryRuntimeList)
create local streamJunctions through which events received by partitionStreamReceiver, are sent to
queryStreamReceivers
|
String |
getStreamId() |
void |
init() |
void |
receive(ComplexEvent complexEvent) |
void |
receive(Event event) |
void |
receive(Event[] events) |
void |
receive(List<Event> events) |
void |
receive(long timestamp,
Object[] data) |
public PartitionStreamReceiver(SiddhiAppContext siddhiAppContext, MetaStreamEvent metaStreamEvent, io.siddhi.query.api.definition.StreamDefinition streamDefinition, List<PartitionExecutor> partitionExecutors, PartitionRuntime partitionRuntime)
public void init()
public String getStreamId()
getStreamId
in interface StreamJunction.Receiver
public void receive(ComplexEvent complexEvent)
receive
in interface StreamJunction.Receiver
public void receive(Event event)
receive
in interface StreamJunction.Receiver
public void receive(long timestamp, Object[] data)
receive
in interface StreamJunction.Receiver
public void receive(Event[] events)
receive
in interface StreamJunction.Receiver
public void receive(List<Event> events)
receive
in interface StreamJunction.Receiver
public void addStreamJunction(List<QueryRuntime> queryRuntimeList)
queryRuntimeList
- queryRuntime list of the partitionCopyright © 2019. All rights reserved.