daft.Expression.partitioning.iceberg_bucket

daft.Expression.partitioning.iceberg_bucket#

Expression.partitioning.iceberg_bucket(n: int) Expression[source]#

Partitioning Transform that returns the Hash Bucket following the Iceberg Specification of murmur3_32_x86 https://iceberg.apache.org/spec/#appendix-b-32-bit-hash-requirements

Parameters:

n (int) – Number of buckets

Returns:

Int32 Expression with the Hash Bucket

Return type:

Expression