Package | Description |
---|---|
io.siddhi.core.query.input | |
io.siddhi.core.query.input.stream.single | |
io.siddhi.core.query.input.stream.state.receiver | |
io.siddhi.core.util.parser |
Class and Description |
---|
MultiProcessStreamReceiver
{StreamJunction.Receiver} implementation to receive events to be fed into multi
stream processors which consume multiple streams.
|
MultiProcessStreamReceiver.ReturnEventHolder
Class to hold the events which are differed publishing
|
ProcessStreamReceiver
Parent implementation for all process stream receivers(Multi/Single/State).
|
Class and Description |
---|
ProcessStreamReceiver
Parent implementation for all process stream receivers(Multi/Single/State).
|
Class and Description |
---|
MultiProcessStreamReceiver
{StreamJunction.Receiver} implementation to receive events to be fed into multi
stream processors which consume multiple streams.
|
ProcessStreamReceiver
Parent implementation for all process stream receivers(Multi/Single/State).
|
SingleProcessStreamReceiver
Implementation of {StreamJunction.Receiver} to receive events to be fed into
single stream stateless queries(Filter).
|
StateMultiProcessStreamReceiver
Implementation of {StreamJunction.Receiver} to receive events to be fed into
multi stream stateful queries.
|
Class and Description |
---|
ProcessStreamReceiver
Parent implementation for all process stream receivers(Multi/Single/State).
|
Copyright © 2019. All rights reserved.