Add ARBITRARY_DISTRIBUTION to SystemPartitioningHandle
Arbitrary distribution happens when rows are naturally
partitioned on arbitrary nodes (might be unfixed) and
there doesn't exists a specific paritioning function.
This happens with AssignUniqueId operator for example.
@@ -51,7 +51,8 @@ public final class SystemPartitioningHandle
FIXED,
SOURCE,
SCALED,
- COORDINATOR_ONLY
+ COORDINATOR_ONLY,
+ ARBITRARY
}
public static final PartitioningHandle SINGLE_DISTRIBUTION = createSystemPartitioning(SystemPartitioning.SINGLE, SystemPartitionFunction.SINGLE);
@@ -61,6 +62,7 @@ public final class SystemPartitioningHandle
public static final PartitioningHandle FIXED_BROADCAST_DISTRIBUTION = createSystemPartitioning(SystemPartitioning.FIXED, SystemPartitionFunction.BROADCAST);
public static final PartitioningHandle SCALED_WRITER_DISTRIBUTION = createSystemPartitioning(SystemPartitioning.SCALED, SystemPartitionFunction.ROUND_ROBIN);
public static final PartitioningHandle SOURCE_DISTRIBUTION = createSystemPartitioning(SystemPartitioning.SOURCE, SystemPartitionFunction.UNKNOWN);
+ public static final PartitioningHandle ARBITRARY_DISTRIBUTION = createSystemPartitioning(SystemPartitioning.ARBITRARY, SystemPartitionFunction.UNKNOWN);
private static PartitioningHandle createSystemPartitioning(SystemPartitioning partitioning, SystemPartitionFunction function)
{
