Module create_sink 

Structs

SinkPlanContext

Enums

SinkCreateMode 🔒

Constants

SINK_SINCE_TIMESTAMP_OPTION 🔒

Statics

CONNECTORS_COMPATIBLE_FORMATS 🔒

SINK_ALLOWED_CONNECTION_CONNECTOR 🔒

SINK_ALLOWED_CONNECTION_SCHEMA_REGISTRY 🔒

Functions

bind_sink_format_desc 🔒

Transforms the (format, encode, options) from sqlparser AST into an internal struct SinkFormatDesc. This is an analogy to (part of) crate::handler::create_source::bind_columns_from_source which transforms sqlparser AST SourceSchemaV2 into StreamSourceInfo.

create_sink_or_replace 🔒

derive_default_column_project_for_sink 🔒

derive_sink_to_table_expr 🔒

fetch_incoming_sinks

gen_sink_plan

get_partition_compute_info

get_partition_compute_info_for_iceberg 🔒

handle_create_sink

prepare_replace_sink 🔒

sink_replace_requires_exactly_once_state 🔒

validate_compatibility