public final class BucketPartitioningDTO extends java.lang.Object implements Partitioning
Partitioning.SingleFieldPartitioning, Partitioning.StrategyTransform.SingleFieldTransformEMPTY_PARTITIONINGEMPTY_EXPRESSION, EMPTY_NAMED_REFERENCE| Modifier and Type | Method and Description |
|---|---|
Expression[] |
arguments() |
java.lang.String[][] |
fieldNames() |
java.lang.String |
name() |
int |
numBuckets() |
static BucketPartitioningDTO |
of(int numBuckets,
java.lang.String[]... fieldNames) |
Partitioning.Strategy |
strategy() |
void |
validate(ColumnDTO[] columns) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitassignments, childrenreferencespublic static BucketPartitioningDTO of(int numBuckets, java.lang.String[]... fieldNames)
public int numBuckets()
public java.lang.String[][] fieldNames()
public Partitioning.Strategy strategy()
strategy in interface Partitioningpublic void validate(ColumnDTO[] columns) throws java.lang.IllegalArgumentException
validate in interface Partitioningjava.lang.IllegalArgumentExceptionpublic java.lang.String name()
public Expression[] arguments()