Interface | Description |
---|---|
StreamingQuery |
:: Experimental ::
A handle to a query that is executing continuously in the background as new data arrives.
|
StreamingQueryListener.Event |
:: Experimental ::
Base type of
StreamingQueryListener events |
Trigger |
:: Experimental ::
Used to indicate how often results should be produced by a
StreamingQuery . |
Class | Description |
---|---|
DataStreamReader |
Interface used to load a streaming
Dataset from external storage systems (e.g. |
DataStreamWriter<T> |
:: Experimental ::
Interface used to write a streaming
Dataset to external storage systems (e.g. |
OutputMode |
:: Experimental ::
OutputMode is used to what data will be written to a streaming sink when there is
new data available in a streaming DataFrame/Dataset.
|
ProcessingTime |
:: Experimental ::
A trigger that runs a query periodically based on the processing time.
|
SinkStatus |
:: Experimental ::
Status and metrics of a streaming
Sink . |
SourceStatus |
:: Experimental ::
Status and metrics of a streaming
Source . |
StreamingQueryInfo |
:: Experimental ::
A class used to report information about the progress of a
StreamingQuery . |
StreamingQueryListener |
:: Experimental ::
Interface for listening to events related to
StreamingQueries . |
StreamingQueryListener.QueryProgress |
:: Experimental ::
Event representing any progress updates in a query
|
StreamingQueryListener.QueryStarted |
:: Experimental ::
Event representing the start of a query
|
StreamingQueryListener.QueryTerminated |
:: Experimental ::
Event representing that termination of a query
|
StreamingQueryManager |
:: Experimental ::
A class to manage all the
StreamingQuery active on a SparkSession . |
Exception | Description |
---|---|
StreamingQueryException |
:: Experimental ::
Exception that stopped a
StreamingQuery . |