Spark 3.5.5 ScalaDoc - org.apache.spark.sql.streaming.StreamingQueryManager (original) (raw)

class StreamingQueryManager extends Logging

 

Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. StreamingQueryManager

2. Logging

3. AnyRef

4. Any

5. Hide All

6. Show All

Value Members

1.  final def !=(arg0: Any): Boolean
2.  final def ##(): Int
3.  final def ==(arg0: Any): Boolean
4.  def active: Array[StreamingQuery]
5.  def addListener(listener: StreamingQueryListener): Unit
6.  final def asInstanceOf[T0]: T0
7.  def awaitAnyTermination(timeoutMs: Long): Boolean
8.  def awaitAnyTermination(): Unit
9.  def clone(): AnyRef
10.  final def eq(arg0: AnyRef): Boolean
11.  def equals(arg0: Any): Boolean
12.  def finalize(): Unit
13.  def get(id: String): StreamingQuery
14.  def get(id: UUID): StreamingQuery
15.  final def getClass(): Class[_]
16.  def hashCode(): Int
17.  def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean
18.  def initializeLogIfNecessary(isInterpreter: Boolean): Unit
19.  final def isInstanceOf[T0]: Boolean
20.  def isTraceEnabled(): Boolean
21.  def listListeners(): Array[StreamingQueryListener]
22.  def log: Logger
23.  def logDebug(msg: ⇒ String, throwable: Throwable): Unit
24.  def logDebug(msg: ⇒ String): Unit
25.  def logError(msg: ⇒ String, throwable: Throwable): Unit
26.  def logError(msg: ⇒ String): Unit
27.  def logInfo(msg: ⇒ String, throwable: Throwable): Unit
28.  def logInfo(msg: ⇒ String): Unit
29.  def logName: String
30.  def logTrace(msg: ⇒ String, throwable: Throwable): Unit
31.  def logTrace(msg: ⇒ String): Unit
32.  def logWarning(msg: ⇒ String, throwable: Throwable): Unit
33.  def logWarning(msg: ⇒ String): Unit
34.  final def ne(arg0: AnyRef): Boolean
35.  final def notify(): Unit
36.  final def notifyAll(): Unit
37.  def removeListener(listener: StreamingQueryListener): Unit
38.  def resetTerminated(): Unit
39.  final def synchronized[T0](arg0: ⇒ T0): T0
40.  def toString(): String
41.  final def wait(): Unit
42.  final def wait(arg0: Long, arg1: Int): Unit
43.  final def wait(arg0: Long): Unit

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped