static KeyDrivenDataDistribution |
KeyDrivenDataDistribution.hashed(String... keys) |
Returns a distribution that distributes based on a hashcode of
the named key fields.
|
static KeyDrivenDataDistribution |
KeyDrivenDataDistribution.hashed(List<String> keys) |
Returns a distribution that distributes based on a hashcode of
the named key fields.
|
static KeyDrivenDataDistribution |
KeyDrivenDataDistribution.keyed(PartitioningFunction basePartitionFunction,
String... keys) |
Returns a distribution that distributes based on the given function
of the named key fields.
|
static KeyDrivenDataDistribution |
KeyDrivenDataDistribution.keyed(PartitioningFunction basePartitionFunction,
List<String> keys) |
Returns a distribution that distributes based on the given function
of the named key fields.
|
static KeyDrivenDataDistribution |
KeyDrivenDataDistribution.localKeyed(PartitioningFunction basePartitionFunction,
List<String> keys) |
For advanced use only; this redistributes per-JVM but not across the cluster.
|
static KeyDrivenDataDistribution |
MetadataUtil.negotiate(DataDistribution distribution,
String... keys) |
Negotiates the required data distribution with the specified distribution
using the given grouping fields.
|
static KeyDrivenDataDistribution |
MetadataUtil.negotiateGrouping(MetadataCalculationContext ctx,
RecordPort port,
SortKey... keys) |
Negotiates the required data distribution on the specified port
using the given grouping fields with sort ordering.
|
static KeyDrivenDataDistribution |
MetadataUtil.negotiateGrouping(MetadataCalculationContext ctx,
RecordPort port,
String... keys) |
Negotiates the required data ordering and distribution on the specified port
using the given grouping fields.
|
static KeyDrivenDataDistribution |
KeyDrivenDataDistribution.ranges(List<RecordToken> boundaries) |
Returns a distribution that distributes based on specified range boundaries
|