GroupState - get, exists, update, remove | 5 ms | Passed |
GroupState - getCurrentProcessingTimeMs | 1 ms | Passed |
GroupState - getCurrentWatermarkMs | 1 ms | Passed |
GroupState - hasTimedOut | 1 ms | Passed |
GroupState - illegal params to setTimeout | 5 ms | Passed |
GroupState - primitive type | 1 ms | Passed |
GroupState - setTimeout - with EventTimeTimeout | 0 ms | Passed |
GroupState - setTimeout - with NoTimeout | 4 ms | Passed |
GroupState - setTimeout - with ProcessingTimeTimeout | 1 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - no prior state - no update | 10 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - no prior state - setting timeout with state removal not allowed | 10 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - no prior state - setting timeout without init state not allowed | 11 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - no prior state - state and timeout timestamp updated | 12 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - no prior state - state removed | 12 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - no prior state - state updated | 12 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - no prior state - timeout timestamp updated to before watermark | 11 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - no update | 12 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - setting timeout with state removal not allowed | 10 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - state and timeout timestamp updated | 10 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - state removed | 16 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - state updated | 14 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - prior state set, no prior timeout - timeout timestamp updated to before watermark | 10 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - no update | 16 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - setting timeout with state removal not allowed | 13 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - state and timeout timestamp updated | 13 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - state removed | 10 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - state updated | 13 ms | Passed |
InputProcessor - process new data - EventTimeTimeout - prior state set, prior timeout set - timeout timestamp updated to before watermark | 15 ms | Passed |
InputProcessor - process new data - NoTimeout - no prior state - no update | 34 ms | Passed |
InputProcessor - process new data - NoTimeout - no prior state - state removed | 9 ms | Passed |
InputProcessor - process new data - NoTimeout - no prior state - state updated | 26 ms | Passed |
InputProcessor - process new data - NoTimeout - prior state set - no update | 12 ms | Passed |
InputProcessor - process new data - NoTimeout - prior state set - state removed | 14 ms | Passed |
InputProcessor - process new data - NoTimeout - prior state set - state updated | 12 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - no update | 11 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - state and timeout duration updated | 13 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - state removed | 11 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - state updated | 20 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - timeout updated after state removed | 12 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - no prior state - timeout updated without initializing state | 12 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - no update | 10 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - state and timeout duration updated | 10 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - state removed | 12 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - state updated | 13 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, no prior timeout - timeout updated after state removed | 10 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - no update | 11 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - state and timeout duration updated | 12 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - state removed | 13 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - state updated | 11 ms | Passed |
InputProcessor - process new data - ProcessingTimeTimeout - prior state set, prior timeout set - timeout updated after state removed | 13 ms | Passed |
InputProcessor - process timed out state - EventTimeTimeout - should not timeout | 10 ms | Passed |
InputProcessor - process timed out state - EventTimeTimeout - should timeout - no update/remove | 10 ms | Passed |
InputProcessor - process timed out state - EventTimeTimeout - should timeout - remove state | 10 ms | Passed |
InputProcessor - process timed out state - EventTimeTimeout - should timeout - timeout and state updated | 10 ms | Passed |
InputProcessor - process timed out state - EventTimeTimeout - should timeout - timeout timestamp updated | 13 ms | Passed |
InputProcessor - process timed out state - EventTimeTimeout - should timeout - update state | 11 ms | Passed |
InputProcessor - process timed out state - ProcessingTimeTimeout - should not timeout | 12 ms | Passed |
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - no update/remove | 12 ms | Passed |
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - remove state | 10 ms | Passed |
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - timeout duration and state updated | 10 ms | Passed |
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - timeout duration updated | 10 ms | Passed |
InputProcessor - process timed out state - ProcessingTimeTimeout - should timeout - update state | 10 ms | Passed |
SPARK-20714: watermark does not fail query when timeout = NoTimeout | 0.34 sec | Passed |
SPARK-20714: watermark does not fail query when timeout = ProcessingTimeTimeout | 0.31 sec | Passed |
abort on task failure handling | 0.91 sec | Passed |
disallow complete mode | 11 ms | Passed |
flatMapGroupsWithState - batch | 0.33 sec | Passed |
flatMapGroupsWithState - recovery from checkpoint uses state format version 1 | 0.72 sec | Passed |
flatMapGroupsWithState - streaming + aggregation - state format version 1 | 3.3 sec | Passed |
flatMapGroupsWithState - streaming + aggregation - state format version 2 | 3 sec | Passed |
flatMapGroupsWithState - streaming + func returns iterator that updates state lazily | 0.89 sec | Passed |
flatMapGroupsWithState - streaming - state format version 1 | 1.5 sec | Passed |
flatMapGroupsWithState - streaming - state format version 2 | 1 sec | Passed |
flatMapGroupsWithState - streaming w/ event time timeout + watermark - state format version 1 | 1.8 sec | Passed |
flatMapGroupsWithState - streaming w/ event time timeout + watermark - state format version 2 | 1.5 sec | Passed |
flatMapGroupsWithState - streaming with processing time timeout - state format version 1 | 1.4 sec | Passed |
flatMapGroupsWithState - streaming with processing time timeout - state format version 2 | 1.3 sec | Passed |
flatMapGroupsWithState - uses state format version 2 by default | 0.27 sec | Passed |
mapGroupsWithState - batch | 0.33 sec | Passed |
mapGroupsWithState - streaming | 1.2 sec | Passed |
output partitioning is unknown | 0.3 sec | Passed |