laminar_connectors/schema/
mod.rs

1//! Schema evolution, format codecs, and connector schema traits.
2
3pub mod csv;
4pub mod error;
5pub mod evolution;
6pub mod json;
7pub mod traits;
8pub mod types;
9
10#[cfg(any(feature = "parquet-lookup", feature = "files"))]
11pub mod parquet;
12
13pub use csv::{
14    CsvDecoder, CsvDecoderConfig, CsvEncoder, CsvEncoderConfig, FieldCountMismatchStrategy,
15};
16pub use error::{SchemaError, SchemaResult};
17pub use evolution::{
18    diff_schemas_by_name, is_safe_widening, EvolutionResult, EvolutionTrigger, SchemaEvolution,
19    SchemaEvolutionEngine, SchemaHistory, SchemaHistoryEntry,
20};
21pub use json::{
22    JsonDecoder, JsonDecoderConfig, JsonEncoder, JsonbAccessor, JsonbEncoder, TypeMismatchStrategy,
23    UnknownFieldStrategy,
24};
25#[cfg(any(feature = "parquet-lookup", feature = "files"))]
26pub use parquet::{
27    ParquetDecoder, ParquetDecoderConfig, ParquetEncoder, ParquetEncoderConfig,
28    ParquetSchemaProvider, RowGroupPredicate,
29};
30pub use traits::{
31    ArrayInference, ColumnProjection, CompatibilityMode, ConfigOption, ConfigValueType,
32    ConnectorConfigSchema, EvolutionVerdict, FieldInferenceDetail, FormatDecoder, FormatEncoder,
33    InferenceConfig, InferenceWarning, InferredSchema, NumberInference, RegisteredSchema,
34    RegistryConfig, RegistryCredentials, RegistrySchemaType, SchemaChange, SchemaProvider,
35    SchemaRegistryAware, WarningSeverity,
36};
37pub use types::{FieldMeta, RawRecord, SinkConfig, SourceConfig, SourceMetadata};
laminar_connectors/schema/mod.rs

laminar_connectors/schema/
mod.rs
