org.apache.iceberg

Class Partitioning

java.lang.Object

org.apache.iceberg.Partitioning

public class Partitioning
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static boolean	hasBucketField(PartitionSpec spec) Check whether the spec contains a bucketed partition field.
static Types.StructType	partitionType(Table table) Builds a common partition type for all specs in a table.
static SortOrder	sortOrderFor(PartitionSpec spec) Create a sort order that will group data for a partition spec.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

hasBucketField

public static boolean hasBucketField(PartitionSpec spec)

Check whether the spec contains a bucketed partition field.

Parameters:

spec - a partition spec

Returns:

true if the spec has field with a bucket transform

sortOrderFor

public static SortOrder sortOrderFor(PartitionSpec spec)

Create a sort order that will group data for a partition spec.

If the partition spec contains bucket columns, the sort order will also have a field to sort by a column that is bucketed in the spec. The column is selected by the highest number of buckets in the transform.

Parameters:

spec - a partition spec

Returns:

a sort order that will cluster data for the spec

partitionType

public static Types.StructType partitionType(Table table)

Builds a common partition type for all specs in a table.

Whenever a table has multiple specs, the partition type is a struct containing all columns that have ever been a part of any spec in the table.

Parameters:

table - a table with one or many specs

Returns:

the constructed common partition type