Package org.apache.iceberg

Class PartitionSpec

java.lang.Object

org.apache.iceberg.PartitionSpec

All Implemented Interfaces:

java.io.Serializable

public class PartitionSpec
extends java.lang.Object
implements java.io.Serializable

Represents how to produce partition data for a table.

Partition data is produced by transforming columns in a table. Each column transform is represented by a named PartitionField.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PartitionSpec.Builder	Used to create valid partition specs.

Method Summary

Modifier and Type	Method	Description
static PartitionSpec.Builder	builderFor(Schema schema)	Creates a new partition spec builder for the given Schema.
boolean	compatibleWith(PartitionSpec other)	Returns true if this spec is equivalent to the other, with field names and partition field ids ignored.
boolean	equals(java.lang.Object other)
java.util.List<PartitionField>	fields()
java.util.List<PartitionField>	getFieldsBySourceId(int fieldId)
int	hashCode()
java.util.Set<java.lang.Integer>	identitySourceIds()	Returns the source field ids for identity partitions.
java.lang.Class<?>[]	javaClasses()
java.lang.String	partitionToPath(StructLike data)
Types.StructType	partitionType()
Schema	schema()
int	specId()
java.lang.String	toString()
static PartitionSpec	unpartitioned()	Returns a spec for unpartitioned tables.

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

schema

public Schema schema()

Returns:

the Schema for this spec.

specId

public int specId()

Returns:

the ID of this spec

fields

public java.util.List<PartitionField> fields()

Returns:

the list of partition fields for this spec.

getFieldsBySourceId

public java.util.List<PartitionField> getFieldsBySourceId(int fieldId)

Parameters:

fieldId - a field id from the source schema

Returns:

the field that partitions the given source field

partitionType

public Types.StructType partitionType()

Returns:

a Types.StructType for partition data defined by this spec.

javaClasses

public java.lang.Class<?>[] javaClasses()

partitionToPath

public java.lang.String partitionToPath(StructLike data)

compatibleWith

public boolean compatibleWith(PartitionSpec other)

Returns true if this spec is equivalent to the other, with field names and partition field ids ignored. That is, if both specs have the same number of fields, field order, source columns, and transforms.

Parameters:

other - another PartitionSpec

Returns:

true if the specs have the same fields, source columns, and transforms.

equals

public boolean equals(java.lang.Object other)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

identitySourceIds

public java.util.Set<java.lang.Integer> identitySourceIds()

Returns the source field ids for identity partitions.

Returns:

a set of source ids for the identity partitions.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

unpartitioned

public static PartitionSpec unpartitioned()

Returns a spec for unpartitioned tables.

Returns:

a partition spec with no partitions

builderFor

public static PartitionSpec.Builder builderFor(Schema schema)

Creates a new partition spec builder for the given Schema.

Parameters:

schema - a schema

Returns:

a partition spec builder for the given schema