Package org.apache.spark.sql.streaming

Interface QueryInfo

All Superinterfaces:
Serializable
public interface QueryInfo extends Serializable
Represents the query info provided to the stateful processor used in the arbitrary state API v2 to easily identify task retries on the same partition.

  • Method Summary

    Modifier and Type
    Method
    Description
    long
    getBatchId()
    Returns the batch id associated with stateful operator
    UUID
    getQueryId()
    Returns the streaming query id associated with stateful operator
    UUID
    getRunId()
    Returns the streaming query runId associated with stateful operator
    String
    toString()
    Returns the string representation of QueryInfo object

  • Method Details

    • getBatchId

      long getBatchId()
      Returns the batch id associated with stateful operator

    • getQueryId

      UUID getQueryId()
      Returns the streaming query id associated with stateful operator

    • getRunId

      UUID getRunId()
      Returns the streaming query runId associated with stateful operator

    • toString

      String toString()
      Returns the string representation of QueryInfo object
      Overrides:
      toString in class Object