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

clean_all_rows_by_sink_id 🔒

report_create_object 🔒