Uses of Class
org.apache.flink.table.catalog.TableDistribution
Packages that use TableDistribution
-
Uses of TableDistribution in org.apache.flink.table.api
Methods in org.apache.flink.table.api that return types with arguments of type TableDistributionConstructors in org.apache.flink.table.api with parameters of type TableDistributionModifierConstructorDescriptionprotectedTableDescriptor(Schema schema, Map<String, String> options, TableDistribution distribution, List<String> partitionKeys, String comment) -
Uses of TableDistribution in org.apache.flink.table.catalog
Methods in org.apache.flink.table.catalog that return TableDistributionModifier and TypeMethodDescriptionstatic TableDistributionTableDistribution.of(TableDistribution.Kind kind, Integer bucketCount, List<String> bucketKeys) Distribution of the given kind over the given keys with a declared number of buckets.static TableDistributionHash distribution over the given keys among the declared number of buckets.static TableDistributionRange distribution over the given keys among the declared number of buckets.static TableDistributionTableDistribution.ofUnknown(int bucketCount) Connector-dependent distribution with a declared number of buckets.static TableDistributionConnector-dependent distribution with a declared number of buckets.Methods in org.apache.flink.table.catalog that return types with arguments of type TableDistributionModifier and TypeMethodDescriptiondefault Optional<TableDistribution>CatalogTable.getDistribution()Returns the distribution of the table if theDISTRIBUTEDclause is defined.Methods in org.apache.flink.table.catalog with parameters of type TableDistributionModifier and TypeMethodDescriptionCatalogTable.Builder.distribution(TableDistribution distribution)