StateStoreId — Unique Identifier of State Store

StateStoreId is…​FIXME

StateStoreId is created when…​FIXME

StateStoreId takes the following when created:

  • Root directory of the checkpoint files

  • Operator ID

  • Partition ID

  • Name of the state store (default: default)

The name of the default state store (for reading state store data that was generated before store names were used, i.e. Spark ⇐ 2.2) is default.

storeCheckpointLocation Method

storeCheckpointLocation(): Path

storeCheckpointLocation…​FIXME

Note
storeCheckpointLocation is used when…​FIXME

results matching ""

    No results matching ""