Structsยง
Functionsยง
- build_
stream_ ๐actors - Assembles
StreamActorinstances from rendered fragment info and job context. - recovery_
table_ ๐with_ upstream_ sinks - For normal DDL operations, the
UpstreamSinkUnionoperator is modified dynamically, and does not persist the newly added or deleted upstreams in meta-store. Therefore, when restoring jobs, we need to restore the information required by the operator based on the current state of the upstream (sink) and downstream (table) of the operator. All necessary metadata must be preloaded before rendering. - render_
runtime_ info