com.datastrato.gravitino.dto.rel.partitioning

Class RangePartitioningDTO

java.lang.Object

com.datastrato.gravitino.dto.rel.partitioning.RangePartitioningDTO

All Implemented Interfaces:

Partitioning, Expression, Transform

public final class RangePartitioningDTO
extends java.lang.Object
implements Partitioning

Represents the range partitioning.

Nested Class Summary

Nested classes/interfaces inherited from interface com.datastrato.gravitino.dto.rel.partitioning.Partitioning

Partitioning.SingleFieldPartitioning, Partitioning.Strategy

Nested classes/interfaces inherited from interface com.datastrato.gravitino.rel.expressions.transforms.Transform

Transform.SingleFieldTransform

Field Summary

Fields inherited from interface com.datastrato.gravitino.dto.rel.partitioning.Partitioning

EMPTY_PARTITIONING

Fields inherited from interface com.datastrato.gravitino.rel.expressions.Expression

EMPTY_EXPRESSION, EMPTY_NAMED_REFERENCE

Method Summary

Modifier and Type	Method and Description
Expression[]	arguments()
RangePartitionDTO[]	assignments()
java.lang.String[]	fieldName()
java.lang.String	name()
static RangePartitioningDTO	of(java.lang.String[] fieldName) Creates a new RangePartitioningDTO with no pre-assigned partitions.
static RangePartitioningDTO	of(java.lang.String[] fieldName, RangePartitionDTO[] assignments) Creates a new RangePartitioningDTO.
Partitioning.Strategy	strategy() Returns the name of the partitioning strategy.
void	validate(ColumnDTO[] columns) Validates the partitioning columns.

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.datastrato.gravitino.rel.expressions.transforms.Transform

children

Methods inherited from interface com.datastrato.gravitino.rel.expressions.Expression

references

Method Detail

of

public static RangePartitioningDTO of(java.lang.String[] fieldName)

Creates a new RangePartitioningDTO with no pre-assigned partitions.

Parameters:

fieldName - The name of the field to partition.

Returns:

The new RangePartitioningDTO.

of

public static RangePartitioningDTO of(java.lang.String[] fieldName,
                                      RangePartitionDTO[] assignments)

Creates a new RangePartitioningDTO.

Parameters:

fieldName - The name of the field to partition.

assignments - The pre-assigned range partitions.

Returns:

The new RangePartitioningDTO.

fieldName

public java.lang.String[] fieldName()

Returns:

The name of the field to partition.

name

public java.lang.String name()

Specified by:

name in interface Transform

Returns:

The name of the partitioning strategy.

assignments

public RangePartitionDTO[] assignments()

Specified by:

assignments in interface Transform

Returns:

The preassigned partitions in the partitioning. Currently, only Transforms.ListTransform and Transforms.RangeTransform need to deal with assignments

arguments

public Expression[] arguments()

Specified by:

arguments in interface Transform

Returns:

The arguments of the partitioning.

strategy

public Partitioning.Strategy strategy()

Description copied from interface: Partitioning

Returns the name of the partitioning strategy.

Specified by:

strategy in interface Partitioning

Returns:

The strategy of the partitioning.

validate

public void validate(ColumnDTO[] columns)
              throws java.lang.IllegalArgumentException

Validates the partitioning columns.

Specified by:

validate in interface Partitioning

Parameters:

columns - The columns to be validated.

Throws:

java.lang.IllegalArgumentException - If the columns are invalid, this exception is thrown.