This stream processor extension performs reordering of an event stream which is out of order.
It implements the AQ-K-Slack based out-of-order handling algorithm which is originally described in
'http://dl.acm.org/citation.cfm?doid=2675743.2771828'.
This stream processor extension performs reordering of an out-of-order event stream.
It implements the K-Slack based out-of-order handling algorithm which is originally described in
'https://www2.informatik.uni-erlangen.de/publication/download/IPDPS2013.pdf'.)
Stream processor performs reordering of out-of-order events optimized for a givenparameter using [AQ-K-Slack algorithm](http://dl.acm.org/citation.cfm?doid=2675743.2771828). This is best for reordering events on attributes those are used for aggregations.data .
Stream processor performs reordering of out-of-order events using [K-Slack algorithm](https://www2.informatik.uni-erlangen.de/publication/download/IPDPS2013.pdf).
Stream processor performs reordering of out-of-order events optimized for a givenparameter using [AQ-K-Slack algorithm](http://dl.acm.org/citation.cfm?doid=2675743.2771828). This is best for reordering events on attributes those are used for aggregations.data .
+Syntax + +``` +reorder:akslack(| Name | +Description | +Default Value | +Possible Data Types | +Optional | +Dynamic | +
|---|---|---|---|---|---|
| timestamp | +The event timestamp on which the events should be ordered. | ++ | LONG | +No | +Yes | +
| correlation.field | +By monitoring the changes in this field Alpha K-Slack dynamically optimises its behavior. This field is used to calculate the runtime window coverage threshold, which represents the upper limit set for unsuccessfully handled late arrivals. | ++ | INT FLOAT LONG DOUBLE |
+ No | +Yes | +
| batch.size | +The parameter 'batch.size' denotes the number of events that should be considered in the calculation of an alpha value. This should be greater than or equal to 15. | +`10,000` | +LONG | +Yes | +No | +
| timeout | +A timeout value in milliseconds, where the buffered events who are older than the given timeout period get flushed every second. | +`-1` (timeout is infinite) | +LONG | +Yes | +No | +
| max.k | +The maximum K-Slack window threshold ('K' parameter). | +`9,223,372,036,854,775,807` (The maximum Long value) | +LONG | +Yes | +No | +
| discard.late.arrival | +If set to true the processor would discarded the out-of-order events arriving later than the K-Slack window, and in otherwise it allows the late arrivals to proceed. |
+ false | +BOOL | +Yes | +No | +
| error.threshold | +The error threshold to be applied in Alpha K-Slack algorithm. | +`0.03` (3%) | +DOUBLE | +Yes | +No | +
| confidence.level | +The confidence level to be applied in Alpha K-Slack algorithm. | +`0.95` (95%) | +DOUBLE | +Yes | +No | +
The query reorders events based on the 'eventTime' attribute value and optimises for aggregating 'volume' attribute considering last 20 events.
+ +### kslack *(Stream Processor)* +Stream processor performs reordering of out-of-order events using [K-Slack algorithm](https://www2.informatik.uni-erlangen.de/publication/download/IPDPS2013.pdf).
+Syntax + +``` +reorder:kslack(| Name | +Description | +Default Value | +Possible Data Types | +Optional | +Dynamic | +
|---|---|---|---|---|---|
| timestamp | +The event timestamp on which the events should be ordered. | ++ | LONG | +No | +Yes | +
| timeout | +A timeout value in milliseconds, where the buffered events who are older than the given timeout period get flushed every second. | +`-1` (timeout is infinite) | +LONG | +Yes | +No | +
| max.k | +The maximum K-Slack window threshold ('K' parameter). | +`9,223,372,036,854,775,807` (The maximum Long value) | +LONG | +Yes | +No | +
| discard.late.arrival | +If set to true the processor would discarded the out-of-order events arriving later than the K-Slack window, and in otherwise it allows the late arrivals to proceed. |
+ false | +BOOL | +Yes | +No | +
The query reorders events based on the 'eventTime' attribute value, and it forcefully flushes all the events who have arrived older than the given 'timeout' value (5000 milliseconds) every second.
This stream processor extension performs reordering of an event stream which is out of order.
It implements the AQ-K-Slack based out-of-order handling algorithm which is originally described in
'http://dl.acm.org/citation.cfm?doid=2675743.2771828'.
Stream processor performs reordering of out-of-order events optimized for a givenparameter using [AQ-K-Slack algorithm](http://dl.acm.org/citation.cfm?doid=2675743.2771828). This is best for reordering events on attributes those are used for aggregations.data .
Syntax + ``` -reorder:akslack(true the processor would discarded the out-of-order events arriving later than the K-Slack window, and in otherwise it allows the late arrivals to proceed.| Name | -Description | -Possible Types | -
|---|---|---|
| beta0 | -The timestamp based on which the reordering is performed. | -LONG | -
| beta1 | -An upper limit value assigned for the unsuccessfully handled late arrivals. | -DOUBLE | -
| beta2 | -The number of events that should be considered in the calculation of an alpha value. | -LONG | -
| beta3 | -The fixed time-out value in milliseconds assigned for flushing all the events buffered inside the extension. | -LONG | -
| beta4 | -The maximum threshold value assigned for 'K' parameter. | -LONG | -
| beta5 | -The flag set to indicate whether the out-of-order events which arrive after buffer eviction are to be discarded or not. | -BOOL | -
| beta6 | -The error threshold value set for Alpha K-Slack algorithm. | -DOUBLE | -
| beta7 | -The confidence level set for the Alpha K-Slack algorithm. | -DOUBLE | -
This query performs reordering based on the 'eventtt' attribute values. In this example, 20 represents the batch size.
- -### kslack *(Stream Processor)* - -This stream processor extension performs reordering of an out-of-order event stream.
It implements the K-Slack based out-of-order handling algorithm which is originally described in
'https://www2.informatik.uni-erlangen.de/publication/download/IPDPS2013.pdf'.)
The query reorders events based on the 'eventTime' attribute value and optimises for aggregating 'volume' attribute considering last 20 events.
+### kslack *(Stream Processor)* +Stream processor performs reordering of out-of-order events using [K-Slack algorithm](https://www2.informatik.uni-erlangen.de/publication/download/IPDPS2013.pdf).
Syntax + ``` -reorder:kslack(true the processor would discarded the out-of-order events arriving later than the K-Slack window, and in otherwise it allows the late arrivals to proceed.This query performs reordering based on the 'eventtt' attribute values. In this example, the timeout value is set to 1000 milliseconds
+The query reorders events based on the 'eventTime' attribute value, and it forcefully flushes all the events who have arrived older than the given 'timeout' value (5000 milliseconds) every second.
This stream processor extension performs reordering of an event stream which is out of order.
It implements the AQ-K-Slack based out-of-order handling algorithm which is originally described in
'http://dl.acm.org/citation.cfm?doid=2675743.2771828'.
This stream processor extension performs reordering of an out-of-order event stream.
It implements the K-Slack based out-of-order handling algorithm which is originally described in
'https://www2.informatik.uni-erlangen.de/publication/download/IPDPS2013.pdf'.)
Stream processor performs reordering of out-of-order events optimized for a givenparameter using [AQ-K-Slack algorithm](http://dl.acm.org/citation.cfm?doid=2675743.2771828). This is best for reordering events on attributes those are used for aggregations.data .
Stream processor performs reordering of out-of-order events using [K-Slack algorithm](https://www2.informatik.uni-erlangen.de/publication/download/IPDPS2013.pdf).