org.apache.beam.sdk.io.iceberg

Class IcebergUtils

java.lang.Object

org.apache.beam.sdk.io.iceberg.IcebergUtils

public class IcebergUtils
extends java.lang.Object

Utilities for converting between Beam and Iceberg types.

Method Summary

Modifier and Type	Method and Description
static org.apache.iceberg.data.Record	beamRowToIcebergRecord(org.apache.iceberg.Schema schema, Row row) Converts a Beam Row to an Iceberg Record.
static org.apache.iceberg.Schema	beamSchemaToIcebergSchema(Schema schema) Converts a Beam Schema to an Iceberg Schema.
static Row	icebergRecordToBeamRow(Schema schema, org.apache.iceberg.data.Record record) Converts an Iceberg Record to a Beam Row.
static Schema	icebergSchemaToBeamSchema(org.apache.iceberg.Schema schema) Converts an Iceberg Schema to a Beam Schema.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

icebergSchemaToBeamSchema

public static Schema icebergSchemaToBeamSchema(org.apache.iceberg.Schema schema)

Converts an Iceberg Schema to a Beam Schema.

beamSchemaToIcebergSchema

public static org.apache.iceberg.Schema beamSchemaToIcebergSchema(Schema schema)

Converts a Beam Schema to an Iceberg Schema.

The following unsupported Beam types will be defaulted to Types.StringType:

Schema.TypeName.DECIMAL Schema.TypeName.DATETIME Schema.TypeName.LOGICAL_TYPE

beamRowToIcebergRecord

public static org.apache.iceberg.data.Record beamRowToIcebergRecord(org.apache.iceberg.Schema schema,
                                                                    Row row)

Converts a Beam Row to an Iceberg Record.

icebergRecordToBeamRow

public static Row icebergRecordToBeamRow(Schema schema,
                                         org.apache.iceberg.data.Record record)

Converts an Iceberg Record to a Beam Row.