Package org.apache.beam.sdk.io.iceberg
package org.apache.beam.sdk.io.iceberg
Iceberg connectors.
-
ClassDescriptionUtilities that convert between a SQL filter expression and an Iceberg
Expression.SchemaTransform implementation forIcebergIO.readRows(org.apache.beam.sdk.io.iceberg.IcebergCatalogConfig).A connector that reads and writes to Apache Iceberg tables.SchemaTransform implementation forIcebergIO.readRows(org.apache.beam.sdk.io.iceberg.IcebergCatalogConfig).Utilities for converting between Beam and Iceberg types, made public for user's convenience.SchemaTransform implementation forIcebergIO.writeRows(org.apache.beam.sdk.io.iceberg.IcebergCatalogConfig).Helper class for source operations.This is an AutoValue representation of an IcebergSnapshot.