Skip to main content

Module streaming_job

risingwave_meta::controller

Module streaming_job 

Source

Structs§

AbortCreatingJobResult
Result of CatalogController::try_abort_creating_streaming_job.
DependentSourceFragmentUpdate 🔒
A planned fragment update for dependent sources when a connection’s properties change.
FinishAutoRefreshSchemaSinkContext
ReplaceOriginalJobInfo 🔒
SinkIntoTableContext

Functions§

job_initial_catalog_resource_group 🔒
serverless_backfill_resource_group_placeholder 🔒
update_connector_props_fragments 🔒
update_sink_fragment_props 🔒
update_stmt_with_props 🔒
validate_sink_props 🔒