paimon-core/src/main/java/org/apache/paimon/table/sink/DynamicBucketRowKeyExtractor.java [33:40]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public DynamicBucketRowKeyExtractor(TableSchema schema) {
        super(schema);
        int numBuckets = new CoreOptions(schema.options()).bucket();
        checkArgument(
                numBuckets == -1,
                "Only 'bucket' = '-1' is allowed for 'DynamicBucketRowKeyExtractor', but found: "
                        + numBuckets);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



paimon-core/src/main/java/org/apache/paimon/table/sink/UnawareBucketRowKeyExtractor.java [29:36]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public UnawareBucketRowKeyExtractor(TableSchema schema) {
        super(schema);
        int numBuckets = new CoreOptions(schema.options()).bucket();
        checkArgument(
                numBuckets == -1,
                "Only 'bucket' = '-1' is allowed for 'UnawareBucketRowKeyExtractor', but found: "
                        + numBuckets);
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -