Skip to content

StatefulOperatorStateInfo

StatefulOperatorStateInfo identifies the state store for a given stateful physical operator:

  • [[checkpointLocation]] Checkpoint directory (checkpointLocation)
  • [[queryRunId]] <> of a streaming query (queryRunId)
  • [[operatorId]] Stateful operator ID (operatorId)
  • [[storeVersion]] <> (storeVersion)
  • [[numPartitions]] Number of partitions

StatefulOperatorStateInfo is <> exclusively when IncrementalExecution is requested for nextStatefulOperationStateInfo.

[[toString]] When requested for a textual representation (toString), StatefulOperatorStateInfo returns the following:

state info [ checkpoint = [checkpointLocation], runId = [queryRunId], opId = [operatorId], ver = [storeVersion], numPartitions = [numPartitions]]

State Version and Batch ID

When created (when IncrementalExecution is requested for the next StatefulOperatorStateInfo), a StatefulOperatorStateInfo is given a state version.

The state version is exactly the batch ID of the IncrementalExecution.