risingwave_
connector
2.4.0-alpha
In risingwave_
connector::
parser::
unified::
debezium
Macros
jsonb_access_field
Structs
DebeziumChangeEvent
MongoJsonAccess
Constants
AFTER
BEFORE
DEBEZIUM_CREATE_OP
DEBEZIUM_DELETE_OP
DEBEZIUM_READ_OP
DEBEZIUM_TRANSACTION_STATUS_BEGIN
DEBEZIUM_TRANSACTION_STATUS_COMMIT
DEBEZIUM_UPDATE_OP
OP
SOURCE
SOURCE_COLLECTION
SOURCE_DB
SOURCE_SCHEMA
SOURCE_TABLE
SOURCE_TS_MS
TABLE_CHANGES
TRANSACTION_ID
TRANSACTION_STATUS
UPSTREAM_DDL
Functions
bson_extract_date
bson_extract_number
bson_extract_timestamp
extract_bson_field
extract_bson_id
parse_schema_change
parse_transaction_meta
risingwave_connector
::
parser
::
unified
::
debezium
Constant
SOURCE_SCHEMA
Copy item path
Settings
Help
Summary
Source
const SOURCE_SCHEMA: &
str
= "schema";