Class: StreamingQueryInfo

eclairjs/sql/streaming. StreamingQueryInfo

A class used to report information about the progress of a StreamingQuery.

Constructor

new StreamingQueryInfo()

Source:

Methods

id() → {number}

Returns the unique id of this query. This id is automatically generated and is unique across all queries that have been started in the current process.
Since:
  • EclairJS 0.7 Spark 2.0.0
Source:
Returns:
Type
number

name() → {string}

Returns the name of the query. This name is unique across all active queries. This can be set in the [[org.apache.spark.sql.DataStreamWriter DataStreamWriter]] as `dataframe.writeStream.queryName("query").start()`.
Since:
  • EclairJS 0.7 Spark 2.0.0
Source:
Returns:
Type
string

sinkStatus() → {module:eclairjs/sql/streaming.SinkStatus}

Returns current status of the sink.
Source:
Returns:
Type
module:eclairjs/sql/streaming.SinkStatus

sourceStatuses() → {Array.<module:eclairjs/sql/streaming.SourceStatus>}

Returns current status of all the sources.
Since:
  • EclairJS 0.7 Spark 2.0.0
Source:
Returns:
Type
Array.<module:eclairjs/sql/streaming.SourceStatus>