org.apache.beam.sdk.io.iceberg

Class IcebergTableCreateConfig

java.lang.Object

org.apache.beam.sdk.io.iceberg.IcebergTableCreateConfig

public abstract class IcebergTableCreateConfig
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IcebergTableCreateConfig.Builder

Constructor Summary

Constructors

Constructor and Description
IcebergTableCreateConfig()

Method Summary

Modifier and Type	Method and Description
static IcebergTableCreateConfig.Builder	builder()
abstract @Nullable java.util.List<java.lang.String>	getPartitionFields()
org.apache.iceberg.PartitionSpec	getPartitionSpec() Partition spec destination, in the event that it must be dynamically created.
abstract Schema	getSchema() Schema for the destination, in the event that it must be dynamically created.

Methods inherited from class java.lang.Object

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

Constructor Detail

IcebergTableCreateConfig

public IcebergTableCreateConfig()

Method Detail

getSchema

@Pure
public abstract Schema getSchema()

Schema for the destination, in the event that it must be dynamically created.

getPartitionSpec

@Pure
public org.apache.iceberg.PartitionSpec getPartitionSpec()

Partition spec destination, in the event that it must be dynamically created.

getPartitionFields

@Pure
public abstract @Nullable java.util.List<java.lang.String> getPartitionFields()

builder

@Pure
public static IcebergTableCreateConfig.Builder builder()