Hierarchy For Package org.apache.spark.sql.streaming

Package Hierarchies:

• All Packages

Class Hierarchy

• Object
  • org.apache.spark.sql.streaming.DataStreamReader (implements org.apache.spark.internal.Logging)
  • org.apache.spark.sql.streaming.DataStreamWriter<T>
  • org.apache.spark.sql.streaming.GroupStateTimeout
  • org.apache.spark.sql.streaming.OutputMode
  • org.apache.spark.sql.streaming.SafeJsonSerializer
  • org.apache.spark.sql.streaming.SinkProgress (implements scala.Serializable)
  • org.apache.spark.sql.streaming.SourceProgress (implements scala.Serializable)
  • org.apache.spark.sql.streaming.StateOperatorProgress (implements scala.Serializable)
  • org.apache.spark.sql.streaming.StreamingQueryListener
  • org.apache.spark.sql.streaming.StreamingQueryListener.QueryProgressEvent (implements org.apache.spark.sql.streaming.StreamingQueryListener.Event)
  • org.apache.spark.sql.streaming.StreamingQueryListener.QueryStartedEvent (implements org.apache.spark.sql.streaming.StreamingQueryListener.Event)
  • org.apache.spark.sql.streaming.StreamingQueryListener.QueryTerminatedEvent (implements org.apache.spark.sql.streaming.StreamingQueryListener.Event)
  • org.apache.spark.sql.streaming.StreamingQueryManager (implements org.apache.spark.internal.Logging)
  • org.apache.spark.sql.streaming.StreamingQueryProgress (implements scala.Serializable)
  • org.apache.spark.sql.streaming.StreamingQueryStatus (implements scala.Serializable)
  • Throwable (implements java.io.Serializable)
    • Exception
      • org.apache.spark.sql.streaming.StreamingQueryException (implements org.apache.spark.SparkThrowable)
  • org.apache.spark.sql.streaming.Trigger

Interface Hierarchy

• org.apache.spark.sql.catalyst.plans.logical.LogicalGroupState<S>
  • org.apache.spark.sql.streaming.GroupState<S>
    • org.apache.spark.sql.streaming.TestGroupState<S>
• org.apache.spark.sql.streaming.PythonStreamingQueryListener
• org.apache.spark.scheduler.SparkListenerEvent
  • org.apache.spark.sql.streaming.StreamingQueryListener.Event
• org.apache.spark.sql.streaming.StreamingQuery