:: Experimental ::
A handle to a query that is executing continuously in the background as new data arrives.
Base type of
Interface used to load a streaming
Interface used to write a streaming
Represents the type of timeouts possible for the Dataset operations `mapGroupsWithState` and `flatMapGroupsWithState`.
OutputMode describes what data will be written to a streaming sink when there is new data available in a streaming DataFrame/Dataset.
Information about progress made for a sink in the execution of a
Information about progress made for a source in the execution of a
Information about updates made to stateful operators in a
Interface for listening to events related to
Event representing any progress updates in a query.
Event representing the start of a query param: id A unique query id that persists across restarts.
Event representing that termination of a query.
A class to manage all the
Information about progress made in the execution of a
Reports information about the instantaneous status of a streaming query.
Policy used to indicate how often results should be produced by a [[StreamingQuery]].
Exception that stopped a