org.apache.flink.table.api

Class TableDescriptor

java.lang.Object

org.apache.flink.table.api.TableDescriptor

@PublicEvolving
public class TableDescriptor
extends Object

Describes a CatalogTable representing a source or sink.

A TableDescriptor is a template for creating a CatalogTable instance. It closely resembles the "CREATE TABLE" SQL DDL statement, containing schema, connector options, and other characteristics. Since tables in Flink are typically backed by external systems, the descriptor describes how a connector (and possibly its format) are configured.

This can be used to register a table in the Table API, see TableEnvironment.createTemporaryTable(String, TableDescriptor).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TableDescriptor.Builder Builder for TableDescriptor.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	TableDescriptor(Schema schema, Map<String,String> options, List<String> partitionKeys, String comment)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object obj)
static TableDescriptor.Builder	forConnector(String connector) Creates a new TableDescriptor.Builder for a table using the given connector.
static TableDescriptor.Builder	forManaged() Creates a new TableDescriptor.Builder for a managed table.
Optional<String>	getComment()
Map<String,String>	getOptions()
List<String>	getPartitionKeys()
Optional<Schema>	getSchema()
int	hashCode()
TableDescriptor.Builder	toBuilder() Converts this immutable instance into a mutable TableDescriptor.Builder.
CatalogTable	toCatalogTable() Converts this descriptor into a CatalogTable.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

TableDescriptor

protected TableDescriptor(@Nullable
                          Schema schema,
                          Map<String,String> options,
                          List<String> partitionKeys,
                          @Nullable
                          String comment)

Method Detail

forConnector

public static TableDescriptor.Builder forConnector(String connector)

Creates a new TableDescriptor.Builder for a table using the given connector.

Parameters:

connector - The factory identifier for the connector.

forManaged

public static TableDescriptor.Builder forManaged()

Creates a new TableDescriptor.Builder for a managed table.

getSchema

public Optional<Schema> getSchema()

getOptions

public Map<String,String> getOptions()

getPartitionKeys

public List<String> getPartitionKeys()

getComment

public Optional<String> getComment()

toCatalogTable

public CatalogTable toCatalogTable()

Converts this descriptor into a CatalogTable.

toBuilder

public TableDescriptor.Builder toBuilder()

Converts this immutable instance into a mutable TableDescriptor.Builder.

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object