class RemoteStreamingQuery extends StreamingQuery
- Alphabetic
- By Inheritance
- RemoteStreamingQuery
- StreamingQuery
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
- new RemoteStreamingQuery(id: UUID, runId: UUID, name: String, sparkSession: SparkSession)
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
awaitTermination(timeoutMs: Long): Boolean
Waits for the termination of
thisquery, either byquery.stop()or by an exception.Waits for the termination of
thisquery, either byquery.stop()or by an exception. If the query has terminated with an exception, then the exception will be thrown. Otherwise, it returns whether the query has terminated or not within thetimeoutMsmilliseconds.If the query has terminated, then all subsequent calls to this method will return
trueimmediately.- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
def
awaitTermination(): Unit
Waits for the termination of
thisquery, either byquery.stop()or by an exception.Waits for the termination of
thisquery, either byquery.stop()or by an exception.If the query has terminated, then all subsequent calls to this method will either return immediately (if the query was terminated by
stop()).- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @IntrinsicCandidate()
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
exception: Option[StreamingQueryException]
Returns the StreamingQueryException if the query was terminated by an exception.
Returns the StreamingQueryException if the query was terminated by an exception.
- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
def
explain(extended: Boolean): Unit
Prints the physical plan to the console for debugging purposes.
Prints the physical plan to the console for debugging purposes.
- extended
whether to do extended explain or not
- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
def
explain(): Unit
Prints the physical plan to the console for debugging purposes.
Prints the physical plan to the console for debugging purposes.
- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
-
val
id: UUID
Returns the unique id of this query that persists across restarts from checkpoint data.
Returns the unique id of this query that persists across restarts from checkpoint data. That is, this id is generated when a query is started for the first time, and will be the same every time it is restarted from checkpoint data. Also see runId.
- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
def
isActive: Boolean
Returns
trueif this query is actively running.Returns
trueif this query is actively running.- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
def
lastProgress: StreamingQueryProgress
Returns the most recent StreamingQueryProgress update of this streaming query.
Returns the most recent StreamingQueryProgress update of this streaming query.
- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
val
name: String
Returns the user-specified name of the query, or null if not specified.
Returns the user-specified name of the query, or null if not specified. This name can be specified in the
org.apache.spark.sql.streaming.DataStreamWriterasdataframe.writeStream.queryName("query").start(). This name, if set, must be unique across all active queries.- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
-
def
processAllAvailable(): Unit
Blocks until all available data in the source has been processed and committed to the sink.
Blocks until all available data in the source has been processed and committed to the sink. This method is intended for testing. Note that in the case of continually arriving data, this method may block forever. Additionally, this method is only guaranteed to block until data that has been synchronously appended data to a
org.apache.spark.sql.execution.streaming.Sourceprior to invocation. (i.e.getOffsetmust immediately reflect the addition).- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
def
recentProgress: Array[StreamingQueryProgress]
Returns an array of the most recent StreamingQueryProgress updates for this query.
Returns an array of the most recent StreamingQueryProgress updates for this query. The number of progress updates retained for each stream is configured by Spark session configuration
spark.sql.streaming.numRecentProgressUpdates.- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
val
runId: UUID
Returns the unique id of this run of the query.
Returns the unique id of this run of the query. That is, every start/restart of a query will generate a unique runId. Therefore, every time a query is restarted from checkpoint, it will have the same id but different runIds.
- Definition Classes
- RemoteStreamingQuery → StreamingQuery
-
val
sparkSession: SparkSession
Returns the
SparkSessionassociated withthis.Returns the
SparkSessionassociated withthis.- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
def
status: StreamingQueryStatus
Returns the current status of the query.
Returns the current status of the query.
- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
def
stop(): Unit
Stops the execution of this query if it is running.
Stops the execution of this query if it is running. This waits until the termination of the query execution threads or until a timeout is hit.
By default stop will block indefinitely. You can configure a timeout by the configuration
spark.sql.streaming.stopTimeout. A timeout of 0 (or negative) milliseconds will block indefinitely. If aTimeoutExceptionis thrown, users can retry stopping the stream. If the issue persists, it is advisable to kill the Spark application.- Definition Classes
- RemoteStreamingQuery → StreamingQuery
- Since
3.5.0
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Deprecated Value Members
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] ) @Deprecated
- Deprecated