Module ingest 

Enums

Format 🔒

Transcoder 🔒

Constants

INGEST_BATCH_SIZE 🔒

Functions

collect_defined_types 🔒

Recursively collects all named type definitions from an Avro schema.

collect_type_references 🔒

Recursively collects type references from an Avro schema JSON value.

extract_all_defined_types 🔒

Extracts ALL type names defined in an Avro schema (including nested types). Returns a set of fully qualified type names.

extract_type_references 🔒

Extracts all type references from an Avro schema JSON string. This finds all fully qualified type names that are referenced but not defined in the schema.

make_transcoder 🔒

run_ingest