Crate risingwave_connector

Modules

aws_utils

connector_common

Common parameters and utilities for both source and sink.

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

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

Structs

WithOptionsSecResolved

Options or properties extracted from the WITH clause of DDLs.

Traits

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 🔒