Module create_sink

Structs

• SinkPlanContext

Statics

• CONNECTORS_COMPATIBLE_FORMATS 🔒

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