| awaitTermination {SparkR} | R Documentation |
Waits for the termination of the query, either by stopQuery or by an error.
awaitTermination(x, timeout = NULL) ## S4 method for signature 'StreamingQuery' awaitTermination(x, timeout = NULL)
x |
a StreamingQuery. |
timeout |
time to wait in milliseconds, if omitted, wait indefinitely until |
If the query has terminated, then all subsequent calls to this method will return TRUE immediately.
TRUE if query has terminated within the timeout period; nothing if timeout is not specified.
awaitTermination(StreamingQuery) since 2.2.0
experimental
Other StreamingQuery methods: explain,
explain, explain,
explain,SparkDataFrame-method,
explain,StreamingQuery-method;
isActive, isActive,
isActive,StreamingQuery-method;
lastProgress, lastProgress,
lastProgress,StreamingQuery-method;
queryName, queryName,
queryName,StreamingQuery-method;
status, status,
status,StreamingQuery-method;
stopQuery, stopQuery,
stopQuery,StreamingQuery-method
## Not run: awaitTermination(sq, 10000)