StreamingQuery

StreamingQuery provides an interface for interacting with a query that executes continuously in background.

Note	`StreamingQuery` is called continuous query or stream query.

StreamingQuery has a name and belongs to a single SQLContext.

Note	`StreamingQuery` is a Scala trait with the only implementation being StreamExecution.

StreamingQuery can be in two states:

If inactive, StreamingQuery may have transitioned into the state due to an StreamingQueryException (that is available under exception).

StreamingQuery tracks current state of all the sources, i.e. SourceStatus, as sourceStatuses.

There could only be a single Sink for a StreamingQuery with many Sources.

StreamingQuery can be stopped by stop or an exception.

results matching ""