Package org.apache.iceberg.flink.sink.dynamic

Interface TableCreator

All Superinterfaces:

Serializable

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface TableCreator
extends Serializable

Field Summary

Fields

Modifier and Type	Field	Description
static final TableCreator	DEFAULT

Method Summary

Modifier and Type	Method	Description
Table	createTable(Catalog catalog, TableIdentifier identifier, Schema schema, PartitionSpec spec)

Field Details

DEFAULT

static final TableCreator DEFAULT

Method Details

createTable

Table createTable(Catalog catalog,
 TableIdentifier identifier,
 Schema schema,
 PartitionSpec spec)