pub fn mongodb_cdc_envelope_schema() -> SchemaRefExpand description
Returns the Arrow schema for MongoDB CDC envelope records.
| Column | Type | Nullable | Description |
|---|---|---|---|
_namespace | Utf8 | no | database.collection |
_op | Utf8 | no | Operation code (I/U/R/D/DROP/…) |
_document_key | Utf8 | no | Document key JSON |
_cluster_time_s | UInt32 | no | Cluster time seconds |
_cluster_time_i | UInt32 | no | Cluster time increment |
_wall_time_ms | Timestamp(ms) | no | Wall clock timestamp |
_full_document | Utf8 | yes | Full document JSON |
_update_desc | Utf8 | yes | Update description JSON |
_resume_token | Utf8 | no | Opaque resume token JSON |