Crate risingwave_connector 

Modules

allow_alter_on_fly_fields

aws_utils

connector_common

Common parameters and utilities for both source and sink.

enforce_secret 🔒

error

jvm_runtime

macros 🔒

parser

schema

sink

source

with_options 🔒

Macros

bail_invalid_option_error

Constructs a InvalidOptionError and bails out.

bail_malformed_response_error

Constructs a MalformedResponseError and bails out.

call_method

call_static_method

dispatch_sink

dispatch_sink_formatter_impl

Macro to dispatch formatting implementation for all supported sink formatter types. Used when the message key can be either bytes or string.

dispatch_sink_formatter_str_key_impl

Macro to dispatch formatting implementation for sink formatters that require string keys. Used when the message key must be a string (excludes some Avro and bytes implementations).

dispatch_source_enum

Usage: dispatch_source_enum!(EnumType, enum_value, |inner_ident| body).

dispatch_source_enum_inner

The invocation:

dispatch_source_prop

dispatch_source_enum with ConnectorProperties as the enum type.

dispatch_split_impl

dispatch_source_enum with SplitImpl as the enum type.

for_all_classified_sources

for_all_connections

for_all_sinks

for_all_sources

for_all_sources_inner

generate_config_use_clauses

generate_config_use_single

impl_cdc_source_type

impl_connection

impl_connector_properties

impl_split

invalid_option_error

Constructs a InvalidOptionError.

malformed_response_error

Constructs a MalformedResponseError.

match_sink_name_str

match_source_name_str

Matches against SourceProperties::SOURCE_NAME to dispatch logic.

match_source_name_str_inner

only_parse_payload

paste

tri

tri! in generators yield Err and return () ? in generators return Err

use_all_sink_configs

Structs

WithOptionsSecResolved

Options or properties extracted from the WITH clause of DDLs.

Constants

AUTO_SCHEMA_CHANGE_KEY

SINK_CREATE_TABLE_IF_NOT_EXISTS_KEY

SINK_INTERMEDIATE_TABLE_NAME

SINK_TARGET_TABLE_NAME

Traits

Get

GetKeyIter

WithPropertiesExt

Utility methods for WITH properties (HashMap and BTreeMap).

Functions

deserialize_bool_from_string 🔒

deserialize_duration_from_string 🔒

deserialize_optional_bool_from_string 🔒

deserialize_optional_string_seq_from_string 🔒

deserialize_optional_u64_seq_from_string 🔒

deserialize_u32_from_string 🔒