SparkR (version 3.1.2)

awaitTermination: awaitTermination

Description

Waits for the termination of the query, either by stopQuery or by an error.

Usage

awaitTermination(x, timeout = NULL)
# S4 method for StreamingQuery
awaitTermination(x, timeout = NULL)

Arguments

x

a StreamingQuery.

timeout

time to wait in milliseconds, if omitted, wait indefinitely until stopQuery is called or an error has occurred.

Value

TRUE if query has terminated within the timeout period; nothing if timeout is not specified.

Details

If the query has terminated, then all subsequent calls to this method will return TRUE immediately.

See Also

Other StreamingQuery methods: explain(), isActive(), lastProgress(), queryName(), status(), stopQuery()

Examples

# NOT RUN {
 awaitTermination(sq, 10000) 
# }