Packages

trait 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.

Annotations
@Evolving()
Source
QueryInfo.scala
Linear Supertypes
Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. QueryInfo
  2. Serializable
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def getBatchId: Long

    Function to return unique batch id associated with stateful operator.

    Function to return unique batch id associated with stateful operator.

    returns

    - the unique batch id.

  2. abstract def getQueryId: UUID

    Function to return unique streaming query id associated with stateful operator.

    Function to return unique streaming query id associated with stateful operator.

    returns

    - the unique query id.

  3. abstract def getRunId: UUID

    Function to return unique streaming query run id associated with stateful operator.

    Function to return unique streaming query run id associated with stateful operator.

    returns

    - the unique query run id.