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.
SinkProgress	:: Experimental :: Information about progress made for a sink in the execution of a StreamingQuery during a trigger.
SourceProgress	:: Experimental :: Information about progress made for a source in the execution of a StreamingQuery during a trigger.
StateOperatorProgress	:: Experimental :: Information about updates made to stateful operators in a StreamingQuery during a trigger.
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 param: id An unique query id that persists across restarts.
StreamingQueryListener.QueryTerminatedEvent	:: Experimental :: Event representing that termination of a query.
StreamingQueryManager	:: Experimental :: A class to manage all the StreamingQuery active on a SparkSession.
StreamingQueryProgress	:: Experimental :: Information about progress made in the execution of a StreamingQuery during a trigger.
StreamingQueryStatus	Reports information about the instantaneous status of a streaming query.

Exception Summary

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