Module streaming_job 

Structs

AbortCreatingJobResult

Result of CatalogController::try_abort_creating_streaming_job.

CancelStreamingJobInfo

Runtime and state cleanup information for canceling a creating streaming job.

DependentSourceFragmentUpdate 🔒

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

FinishAutoRefreshSchemaSinkContext

IndependentJobChangeLogInfo

ReplaceOriginalJobInfo 🔒

SinkIntoTableContext

TableChangeLogTruncateInfo

Functions

ensure_source_props_not_set_by_connection 🔒

job_initial_catalog_resource_group 🔒

merge_with_options 🔒

serverless_backfill_resource_group_placeholder 🔒

update_connector_props_fragments 🔒

update_sink_fragment_props 🔒

update_sink_node_rate_limit 🔒

update_stmt_with_props 🔒

validate_sink_props 🔒

Validates altering alter_props of a sink. altered_field_names are all the keys being altered, including secret-backed ones that are not part of alter_props.