Uses of Class
io.confluent.flink.plugin.ConfluentTableDescriptor.Builder

Packages that use ConfluentTableDescriptor.Builder

Package	Description
io.confluent.flink.plugin

Uses of ConfluentTableDescriptor.Builder in io.confluent.flink.plugin

Methods in io.confluent.flink.plugin that return ConfluentTableDescriptor.Builder

Modifier and Type	Method	Description
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.comment(String comment)	Define the comment for this table.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.distributedBy(int numberOfBuckets, String... bucketKeys)	Defines that the table should be distributed into the given number of buckets by the given columns.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.distributedBy(String... bucketKeys)	Defines that the table should be distributed into buckets over the given columns.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.distributedByHash(int numberOfBuckets, String... bucketKeys)	Defines that the table should be distributed into the given number of buckets using a hash algorithm over the given columns.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.distributedByHash(String... bucketKeys)	Defines that the table should be distributed into buckets using a hash algorithm over the given columns.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.distributedByRange(int numberOfBuckets, String... bucketKeys)	Defines that the table should be distributed into the given number of buckets using a range algorithm over the given columns.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.distributedByRange(String... bucketKeys)	Defines that the table should be distributed into buckets using a range algorithm over the given columns.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.distributedInto(int numberOfBuckets)	Defines that the table should be distributed into the given number of buckets.
static ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.forConnector(String connectorIdentifier)	Creates a TableDescriptor for a table in Confluent Cloud.
static ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.forManaged()	Creates a TableDescriptor for a Confluent-managed table.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.format(String format)	Defines the format to be used for this table.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.format(ConfigOption<String> formatOption, FormatDescriptor formatDescriptor)	Defines the format to be used for this table.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.format(FormatDescriptor formatDescriptor)	Defines the format to be used for this table.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.keyFormat(FormatDescriptor formatDescriptor)	Defines the key format for Kafka-based tables.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.option(String key, String value)	Sets the given option on the table.
<T> ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.option(ConfigOption<T> configOption, T value)	Sets the given option on the table.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.partitionedBy(String... partitionKeys)	Define which columns this table is partitioned by.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.schema(Schema schema)	Define the schema of the TableDescriptor.
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.toBuilder()
ConfluentTableDescriptor.Builder	ConfluentTableDescriptor.Builder.valueFormat(FormatDescriptor formatDescriptor)	Defines the value format for Kafka-based tables.