Module : streams
SnapshottableStreamEvent | This record represents a stream event which can be persisted. |
AbstractOperatorProcessor | Abstract processor encapsulating operator functions. |
AbstractPatternProcessor | Abstract processor encapsulating pattern processor functions. |
Aggregator | Abstract object, which should be implemented in order to create a new aggregator. |
AndOperatorProcessor | Processor to perform AND stream operations. |
Average | Aggregator to calculate average in streams. |
CompoundPatternProcessor | Processor to perform compound stream operations. |
Count | Aggregator to count events in streams. |
DelayWindow | This window will delay the incoming events for a given amount of time.
E.g.
from inputStream window |
DistinctCount | Aggregator to get the distinct counts of values in streams. |
ExternalTimeBatchWindow | This is a batch (tumbling) time window based on external time, that holds events arrived during window time periods,
and gets updated for every window time.
E.g.
from inputStream window |
ExternalTimeWindow | This is a sliding time window based on external time, that holds events for that arrived during last window time
period from the external timestamp, and gets updated on every monotonically increasing timestamp.
E.g.
from inputStream window |
Filter | The |
FollowedByProcessor | Processor to perform FollowedBy stream operations. |
HoppingWindow | The hopping window releases the events in batches defined by a time period every given time interval. The batch is
also determined by the time period given in the window. When the time interval the events being released and the
time period it hold the events are equal, the hopping window acts as a |
IntSort | This class implements a merge sort algorithm to sort timestamp values for state persistence. |
LengthBatchWindow | This is a batch (tumbling) length window, that holds up to the given length of events, and gets updated on every
given number of events arrival.
E.g.
from inputStream window |
LengthWindow | The |
LinkedList | The |
Max | Aggregator to find the maximum value in a stream. |
MaxForever | The aggregator to keep the maximum value received so far. It is similar to |
MergeSort | This object implements the merge sort algorithm to sort the provided value arrays. |
Min | Aggregator to find the minimum value in a stream. |
MinForever | The aggregator to keep the minimum value received so far. It is similar to |
Node | The |
NotOperatorProcessor | |
OperandProcessor | Processor to perform operand processor operations. |
OrOperatorProcessor | Processor to perform OR stream operations. |
OrderBy | The |
OutputProcess | The |
Scheduler | The |
Select | The |
Snapshotable | Abstract Snapshotable to be referenced by all snapshotable objects. |
SortWindow | The sort window hold a given number of events and emit the expired events in the ordered by the given fields.
E.g.
from inputStream window |
StateMachine | StateMachine which performs stream pattern processing. |
StdDev | The aggregator object to calculate standard deviation. |
StreamEvent | The |
StreamJoinProcessor | The |
Sum | Aggregator to perform summation of values in a stream. |
TableJoinProcessor | The |
TimeAccumulatingWindow | The |
TimeBatchWindow | This is a batch (tumbling) time window, that holds events arrived between window time periods, and gets updated for
every window time.
E.g.
from inputStream window |
TimeLengthWindow | This is a sliding time window that, at a given time holds the last windowLength events that arrived during last
windowTime period, and gets updated for every event arrival and expiry.
E.g.
from inputStream window |
TimeOrderWindow | The |
TimeWindow | The |
UniqueLengthWindow | This is a length window which only keeps the unique events.
E.g.
from inputStream window |
Window | The from inputStream window |
avg | Returns a |
buildStreamEvent | Creates |
count | Returns a |
createAndOperatorProcessor | Creates and returns a |
createCompoundPatternProcessor | Creates and returns a |
createFilter | Creates a |
createFollowedByProcessor | Creates and returns a |
createNotOperatorProcessor | Creates and returns a |
createOperandProcessor | Creates and returns a |
createOrOperatorProcessor | Creates and returns a |
createOrderBy | Creates an |
createOutputProcess | Creates and return a |
createResetStreamEvent | Creates a RESET event from a given event. |
createSelect | Creates and returns a select clause. |
createStateMachine | Creates and returns a |
createStreamJoinProcessor | Creates a |
createTableJoinProcessor | Creates a |
delay | The |
distinctCount | Returns a |
externalTime | The |
externalTimeBatch | The |
getStreamEvent | Get the stream event from any? field. This function can only be used only if we are sure that the |
hopping | The |
initPersistence | Function to initialize and start snapshotting. |
length | The |
lengthBatch | The |
max | Returns a |
maxForever | Returns a |
min | Returns a |
minForever | Returns a |
registerSnapshotable | Function to register Snapshotables. |
removeState | Function to clear an existing state. |
restoreState | Function to restore state of a given object. |
sort | The |
stdDev | Returns a |
sum | Returns a |
time | The |
timeAccum | The |
timeBatch | The |
timeLength | The |
timeOrder | The |
toSnapshottableEvent | Convert a single |
toSnapshottableEvents | Converts a given array of streams:StreamEvent objects to an array of |
toStreamEvent | Convert a single |
toStreamEvents | Converts a given array of snapshotable events to an array of |
uniqueLength | The |
OUTPUT | |
RESET | The reset event type |
EXPIRED | The expired event type |
CURRENT | The current event type. |
TIMER | The timer event type. |
DEFAULT | The default key to group by if the group by clause is not used in query |
DELIMITER | |
DELIMITER_REGEX | |
ASCENDING | |
DESCENDING |