Expand description
Schema resolver and merge engine.
The SchemaResolver implements a five-level priority chain for
determining the Arrow schema of a source connector:
- Full DDL — user-declared schema without wildcards
- Schema registry — via
SchemaRegistryAware - Source provider — via
SchemaProvider - Sample inference — via
SchemaInferable - Error — no schema could be determined
When partial DDL is provided (with wildcard *), the resolver merges
user-declared columns with the resolved columns, preserving user-declared
columns first.
Structs§
- Declared
Column - A single column declared in DDL.
- Declared
Schema - A user-declared schema from DDL (e.g.,
CREATE SOURCE ... (col1 INT, ...)). - Resolved
Schema - The result of schema resolution.
- Schema
Resolver - Stateless schema resolver.
Enums§
- Field
Origin - Origin of a single field in a resolved schema.
- Resolution
Kind - How the schema was resolved.