SparkR (version 2.4.6)

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

Run this code
# NOT RUN {
 awaitTermination(sq, 10000) 
# }

Run the code above in your browser using DataCamp Workspace