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

Modifier and Type	Class and Description
static class	RangePartitioningDTO.Builder The builder for the RangePartitioningDTO.

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()
static RangePartitioningDTO.Builder	builder()
java.lang.String[]	fieldName()
java.lang.String	name()
static RangePartitioningDTO	of(java.lang.String[] fieldName) 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

assignments, 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.

Parameters:

fieldName - The name of the field to partition.

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.

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.

builder

public static RangePartitioningDTO.Builder builder()

Returns:

the builder for creating a new instance of RangePartitioningDTO.