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

latestCheckpointLocation¶

latestCheckpointLocation: String

latestCheckpointLocation...FIXME

latestCheckpointLocation is used when:

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