org.apache.beam.sdk.io.iceberg

Class IcebergDestination

java.lang.Object

org.apache.beam.sdk.io.iceberg.IcebergDestination

public abstract class IcebergDestination
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IcebergDestination.Builder

Constructor Summary

Constructors

Constructor and Description
IcebergDestination()

Method Summary

Modifier and Type	Method and Description
static IcebergDestination.Builder	builder()
abstract org.apache.iceberg.FileFormat	getFileFormat() File format for created files.
abstract @Nullable IcebergTableCreateConfig	getTableCreateConfig() Metadata and constraints for creating a new table, if it must be done dynamically.
abstract org.apache.iceberg.catalog.TableIdentifier	getTableIdentifier() The iceberg table identifier to write data to.

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergDestination

public IcebergDestination()

Method Detail

getTableIdentifier

@Pure
public abstract org.apache.iceberg.catalog.TableIdentifier getTableIdentifier()

The iceberg table identifier to write data to. This is relative to the catalog, which is presumed to be configured outside of this destination specification.

getFileFormat

@Pure
public abstract org.apache.iceberg.FileFormat getFileFormat()

File format for created files.

getTableCreateConfig

@Pure
public abstract @Nullable IcebergTableCreateConfig getTableCreateConfig()

Metadata and constraints for creating a new table, if it must be done dynamically.

If null, dynamic table creation will fail, and this should be disallowed at the top level configuration.

builder

@Pure
public static IcebergDestination.Builder builder()