Module streaming_job 

Structs

DependentSourceFragmentUpdate 🔒

A planned fragment update for dependent sources when a connection’s properties change.

FinishAutoRefreshSchemaSinkContext

SinkIntoTableContext

Functions

update_connector_props_fragments 🔒

update_sink_fragment_props 🔒

update_stmt_with_props 🔒

validate_sink_props 🔒