FlowSystemMetadata¶

FlowSystemMetadata is a SystemMetadata associated with a Flow.

Creating Instance¶

FlowSystemMetadata takes the following to be created:

• PipelineUpdateContext
• Flow
• DataflowGraph

FlowSystemMetadata is created when:

• FlowPlanner is requested to plan a StreamingFlow for execution
• State is requested to clear out the state of a flow

Latest Checkpoint Location¶

latestCheckpointLocation: String

latestCheckpointLocation determines the path of the latest checkpoint directory under the checkpoints root directory.

latestCheckpointLocation is used when:

• FlowPlanner is requested to plan a StreamingFlow
• State is requested to reset a flow