com.datastrato.gravitino.dto.rel

Class DistributionDTO

java.lang.Object

com.datastrato.gravitino.dto.rel.DistributionDTO

All Implemented Interfaces:

Distribution, Expression

public class DistributionDTO
extends java.lang.Object
implements Distribution

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DistributionDTO.Builder

Field Summary

Fields

Modifier and Type	Field and Description
static DistributionDTO	NONE

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

EMPTY_EXPRESSION, EMPTY_NAMED_REFERENCE

Method Summary

Modifier and Type	Method and Description
FunctionArg[]	args()
boolean	equals(java.lang.Object o)
Expression[]	expressions()
int	hashCode()
int	number()
Strategy	strategy()
void	validate(ColumnDTO[] columns)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.datastrato.gravitino.rel.expressions.distributions.Distribution

children

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

references

Field Detail

NONE

public static final DistributionDTO NONE

Method Detail

args

public FunctionArg[] args()

strategy

public Strategy strategy()

Specified by:

strategy in interface Distribution

Returns:

the distribution strategy name.

number

public int number()

Specified by:

number in interface Distribution

Returns:

The number of buckets/distribution. For example, if the distribution strategy is HASH and the number is 10, then the data is distributed across 10 buckets.

expressions

public Expression[] expressions()

Specified by:

expressions in interface Distribution

Returns:

The expressions passed to the distribution function.

validate

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

Throws:

java.lang.IllegalArgumentException

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object