MemorySink can recover from a checkpoint in Complete Mode | 1.1 sec | Passed |
SPARK-18510: use user specified types for partition columns in file sources | 0.64 sec | Passed |
SPARK-18927: MemorySink can recover from a checkpoint provided in conf in Complete Mode | 1 sec | Passed |
SPARK-20431: Specify a schema by using a DDL-formatted string | 4 ms | Passed |
SPARK-26586: Streams should have isolated confs | 0.41 sec | Passed |
SPARK-32832: later option should override earlier options for load() | 4 ms | Passed |
SPARK-32832: later option should override earlier options for start() | 38 ms | Passed |
append mode memory sink's do not support checkpoint recovery | 6 ms | Passed |
check foreach() catches null writers | 5 ms | Passed |
check foreach() does not support partitioning | 6 ms | Passed |
options | 50 ms | Passed |
partitioning | 98 ms | Passed |
prevent all column partitioning | 31 ms | Passed |
resolve default source | 0.13 sec | Passed |
resolve full class | 42 ms | Passed |
source metadataPath | 8.2 sec | Passed |
stream paths | 35 ms | Passed |
temp checkpoint dir should be deleted if a query is stopped without errors | 72 ms | Passed |
temp checkpoint dir should not be deleted if a query is stopped with an error | 0.14 sec | Passed |
test different data types for options | 42 ms | Passed |
trigger | 69 ms | Passed |
unique query names | 0.2 sec | Passed |
use SQLConf checkpoint dir when checkpointLocation is not specified | 54 ms | Passed |
use SQLConf checkpoint dir when checkpointLocation is not specified without query name | 41 ms | Passed |
user specified checkpointLocation precedes SQLConf | 54 ms | Passed |
write cannot be called on streaming datasets | 0.22 sec | Passed |