com.datastrato.gravitino.rel.expressions.distributions

Class Distributions.DistributionImpl

java.lang.Object

com.datastrato.gravitino.rel.expressions.distributions.Distributions.DistributionImpl

All Implemented Interfaces:

Distribution, Expression

Enclosing class:

Distributions

public static final class Distributions.DistributionImpl
extends java.lang.Object
implements Distribution

Create a distribution on columns. Like distribute by (a) or (a, b), for complex like distributing by (func(a), b) or (func(a), func(b)), please use Distributions.DistributionImpl.Builder

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Distributions.DistributionImpl.Builder Builder to create a distribution.

Field Summary

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

EMPTY_EXPRESSION, EMPTY_NAMED_REFERENCE

Method Summary

Modifier and Type	Method and Description
Expression[]	expressions()
int	number()
Strategy	strategy()

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.distributions.Distribution

children

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

references

Method Detail

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.