Module create_sink

Structs

SinkPlanContext

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.

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

insert_merger_to_union_with_project 🔒

reparse_table_for_sink 🔒

validate_compatibility