Package org.apache.beam.sdk.io.iceberg

Class IcebergTableCreateConfig

java.lang.Object
org.apache.beam.sdk.io.iceberg.IcebergTableCreateConfig
public abstract class IcebergTableCreateConfig extends Object

  • Constructor Details

    • IcebergTableCreateConfig

      public IcebergTableCreateConfig()

  • Method Details

    • 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 List<String> getPartitionFields()

    • getSortOrder

      @Pure @SchemaIgnore public org.apache.iceberg.SortOrder getSortOrder()
      Sort order to apply when the table is dynamically created.

    • getSortFields

      @Pure public abstract @Nullable List<String> getSortFields()

    • getTableProperties

      @Pure public abstract @Nullable Map<String,String> getTableProperties()

    • builder

      @Pure public static IcebergTableCreateConfig.Builder builder()