Module lookup 

Lookup table support for enrichment joins. Lookup tables for enrichment joins.

Re-exports

pub use postgres_source::PostgresLookupSource;

pub use postgres_source::PostgresLookupSourceConfig;

pub use parquet_source::ParquetLookupSource;

pub use parquet_source::ParquetLookupSourceConfig;

Modules

cdc_adapter

CDC-to-reference-table adapter for using CDC sources as lookup tables. CDC-to-reference-table adapter.

delta_lookup

Delta Lake on-demand lookup source for cache-miss fallback. Delta Lake on-demand lookup source for cache-miss fallback.

delta_reference

Delta Lake reference table source for lookup/enrichment joins. Delta Lake reference table source for lookup/enrichment joins.

parquet_source

Parquet file lookup source for static/slowly-changing dimension tables. Parquet file lookup source.

postgres_reference

PostgreSQL poll-based reference table source (no CDC required). PostgreSQL poll-based reference table source.

postgres_source

PostgreSQL lookup source with connection pooling and predicate pushdown. PostgreSQL lookup source with predicate pushdown.

Structs

NoOpTableLoader

A no-op table loader that always returns NotFound.

Enums

LookupError

Errors from lookup source operations.

LookupResult

Result of a lookup operation.

Traits

TableLoader

Trait for loading data from external reference tables.