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()
    Function to return unique batch id associated with stateful operator.
    UUID
    getQueryId()
    Function to return unique streaming query id associated with stateful operator.
    UUID
    getRunId()
    Function to return unique streaming query run id associated with stateful operator.
    String
    toString()
    Function to return string representation of the query info.

  • Method Details

    • getBatchId

      long getBatchId()
      Function to return unique batch id associated with stateful operator.

      Returns:
      - the unique batch id.

    • getQueryId

      UUID getQueryId()
      Function to return unique streaming query id associated with stateful operator.

      Returns:
      - the unique query id.

    • getRunId

      UUID getRunId()
      Function to return unique streaming query run id associated with stateful operator.

      Returns:
      - the unique query run id.

    • toString

      String toString()
      Function to return string representation of the query info.

      Overrides:
      toString in class Object
      Returns:
      - query info as string.