org.apache.spark.sql.streaming

Interfaces

• GroupState
• PythonStreamingQueryListener
• StreamingQuery
• StreamingQueryListener.Event
• TestGroupState

Classes

• DataStreamReader
• DataStreamWriter
• GroupStateTimeout
• OutputMode
• SafeJsonSerializer
• SinkProgress
• SourceProgress
• StateOperatorProgress
• StreamingQueryListener
• StreamingQueryListener.QueryProgressEvent
• StreamingQueryListener.QueryStartedEvent
• StreamingQueryListener.QueryTerminatedEvent
• StreamingQueryManager
• StreamingQueryProgress
• StreamingQueryStatus
• Trigger

Exceptions

• StreamingQueryException