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.
• 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
• dispatch_source_enum_inner
• dispatch_source_prop
• dispatch_split_impl
• for_all_classified_sources
• for_all_sinks
• for_all_sources
• for_all_sources_inner
• impl_cdc_source_type
• impl_connector_properties
• impl_split
• invalid_option_error
  Constructs a InvalidOptionError.
• 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 🔒