StatefulOperatorStateInfo identifies the state store for a given operator:

  • Checkpoint directory (aka checkpointLocation)

  • Run ID of a streaming query (queryRunId)

  • Stateful operator ID (operatorId)

  • storeVersion

  • Number of partitions

StatefulOperatorStateInfo is created exclusively when IncrementalExecution is requested for nextStatefulOperationStateInfo.

When requested for a textual representation, StatefulOperatorStateInfo returns the following:

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

results matching ""

    No results matching ""