Package | Description |
---|---|
org.apache.flink.table.api |
Modifier and Type | Method and Description |
---|---|
TableDescriptor.Builder |
TableDescriptor.Builder.comment(String comment)
Define the comment for this table.
|
static TableDescriptor.Builder |
TableDescriptor.forConnector(String connector)
Creates a new
TableDescriptor.Builder for a table using the given connector. |
static TableDescriptor.Builder |
TableDescriptor.forManaged()
Creates a new
TableDescriptor.Builder for a managed table. |
TableDescriptor.Builder |
TableDescriptor.Builder.format(ConfigOption<String> formatOption,
FormatDescriptor formatDescriptor)
Defines the format to be used for this table.
|
TableDescriptor.Builder |
TableDescriptor.Builder.format(FormatDescriptor formatDescriptor)
Defines the format to be used for this table.
|
TableDescriptor.Builder |
TableDescriptor.Builder.format(String format)
Defines the
format to be used for this table. |
<T> TableDescriptor.Builder |
TableDescriptor.Builder.option(ConfigOption<T> configOption,
T value)
Sets the given option on the table.
|
TableDescriptor.Builder |
TableDescriptor.Builder.option(String key,
String value)
Sets the given option on the table.
|
TableDescriptor.Builder |
TableDescriptor.Builder.partitionedBy(String... partitionKeys)
Define which columns this table is partitioned by.
|
TableDescriptor.Builder |
TableDescriptor.Builder.schema(Schema schema)
Define the schema of the
TableDescriptor . |
TableDescriptor.Builder |
TableDescriptor.toBuilder()
Converts this immutable instance into a mutable
TableDescriptor.Builder . |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.