Package org.apache.iceberg
Class Partitioning
- java.lang.Object
-
- org.apache.iceberg.Partitioning
-
public class Partitioning extends java.lang.Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method 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.
-
-
-
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
-
-