StatefulOperatorStateInfo identifies the state store for a given operator:

  • Checkpoint directory

  • queryRunId

  • 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 ""