public class BucketComputer extends Object
BucketComputer
to compute bucket by bucket keys or primary keys or whole row.Constructor and Description |
---|
BucketComputer(TableSchema tableSchema) |
Modifier and Type | Method and Description |
---|---|
static int |
bucket(int hashcode,
int numBucket) |
int |
bucket(org.apache.flink.table.data.RowData row) |
int |
bucket(org.apache.flink.table.data.RowData row,
org.apache.flink.table.data.binary.BinaryRowData pk) |
static int |
hashcode(org.apache.flink.table.data.binary.BinaryRowData rowData) |
public BucketComputer(TableSchema tableSchema)
public int bucket(org.apache.flink.table.data.RowData row)
public int bucket(org.apache.flink.table.data.RowData row, org.apache.flink.table.data.binary.BinaryRowData pk)
public static int hashcode(org.apache.flink.table.data.binary.BinaryRowData rowData)
public static int bucket(int hashcode, int numBucket)
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.