org.apache.beam.sdk.io.iceberg

Class IcebergIO

java.lang.Object

org.apache.beam.sdk.io.iceberg.IcebergIO

@Internal
public class IcebergIO
extends java.lang.Object

The underlying Iceberg connector used by Managed.ICEBERG. Not intended to be used directly.

For internal use only; no backwards compatibility guarantees

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IcebergIO.ReadRows
static class	IcebergIO.WriteRows

Constructor Summary

Constructors

Constructor and Description
IcebergIO()

Method Summary

Modifier and Type	Method and Description
static IcebergIO.ReadRows	readRows(IcebergCatalogConfig catalogConfig)
static IcebergIO.WriteRows	writeRows(IcebergCatalogConfig catalog)

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergIO

public IcebergIO()

Method Detail

writeRows

public static IcebergIO.WriteRows writeRows(IcebergCatalogConfig catalog)

readRows

public static IcebergIO.ReadRows readRows(IcebergCatalogConfig catalogConfig)