Package org.apache.spark.sql.streaming

Interface Summary

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 Summary

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.
StreamingQueryListener	:: Experimental :: Interface for listening to events related to StreamingQueries.
StreamingQueryListener.QueryProgressEvent	:: Experimental :: Event representing any progress updates in a query
StreamingQueryListener.QueryStartedEvent	:: Experimental :: Event representing the start of a query
StreamingQueryListener.QueryTerminatedEvent	:: Experimental :: Event representing that termination of a query
StreamingQueryManager	:: Experimental :: A class to manage all the StreamingQuery active on a SparkSession.
StreamingQueryStatus	:: Experimental :: A class used to report information about the progress of a StreamingQuery.

Exception Summary

Exception	Description
StreamingQueryException	:: Experimental :: Exception that stopped a StreamingQuery.