public final class UnspecifiedPartialDistribution extends PartialStaticDataDistribution
Modifier and Type | Field and Description |
---|---|
static UnspecifiedPartialDistribution |
INSTANCE
The singleton instance of this class.
|
Modifier and Type | Method and Description |
---|---|
AliasSet[] |
getAliases()
Returns the fields that are referenced by this distribution.
|
protected PartitioningFunction |
getPartitioningFunction()
Subclasses must override this method to provide the partitioning function to be used
|
protected com.pervasive.datarush.operators.partition.internal.PartitionOperator |
getPartitionOperator(int partitionCount) |
UnspecifiedPartialDistribution |
remap(FieldRemapping mapping)
Because UnspecifiedPartialDistribution does not
reference any key names, it is not sensitive to transformations to the record namespace
and thus this method just returns a reference to this, unmodified.
|
protected boolean |
requiresRepartitionFrom(PartialDataDistribution source)
Subclasses must override this method to declare whether a repartition is required given the source
distribution.
|
protected boolean |
supportsLocalRepartition()
Subclasses may override to indicate that they support a local repartition
|
String |
toString() |
getGatherScheme
public static final UnspecifiedPartialDistribution INSTANCE
public String toString()
toString
in class DataDistribution
public UnspecifiedPartialDistribution remap(FieldRemapping mapping)
remap
in class DataDistribution
mapping
- the field remapping.protected boolean requiresRepartitionFrom(PartialDataDistribution source)
PartialStaticDataDistribution
requiresRepartitionFrom
in class PartialStaticDataDistribution
source
- the source distributionpublic AliasSet[] getAliases()
DataDistribution
getAliases
in class DataDistribution
protected com.pervasive.datarush.operators.partition.internal.PartitionOperator getPartitionOperator(int partitionCount)
protected PartitioningFunction getPartitioningFunction()
PartialStaticDataDistribution
getPartitioningFunction
in class PartialStaticDataDistribution
protected boolean supportsLocalRepartition()
PartialStaticDataDistribution
supportsLocalRepartition
in class PartialStaticDataDistribution
Copyright © 2024 Actian Corporation. All rights reserved.