Module ddl_controller

Structs

CreatingStreamingJobPermit

DdlController

ReplaceStreamJobInfo

It’s used to describe the information of the job that needs to be replaced and it will be used during replacing table and creating sink into table operations.

Enums

DdlCommand

DropMode

StreamingJobId

Functions

build_upstream_sink_info

clean_all_rows_by_sink_id 🔒

refill_upstream_sink_union_in_table

report_create_object 🔒