public class DataPartitioner extends java.lang.Object implements IDataPartitionFunction
Constructor and Description |
---|
DataPartitioner() |
DataPartitioner(int sm,
int par) |
Modifier and Type | Method and Description |
---|---|
void |
checkData(int para,
int count) |
void |
doDefaultLoad() |
void |
doEquiLoad() |
void |
doWeightedLoad() |
java.util.HashMap<java.lang.Integer,java.lang.Integer> |
getDataDistribution(int par,
int count,
DataPartitionType partitionType) |
java.util.HashMap<java.lang.Integer,java.lang.Integer> |
getDataPartitionMap() |
DataPartitioner |
partition() |
DataPartitioner |
withImbalancePartitionId(int imbalanceId) |
DataPartitioner |
withParallelism(int par) |
DataPartitioner |
withPartitionType(DataPartitionType partitionType) |
DataPartitioner |
withSamples(int sm) |
public DataPartitioner()
public DataPartitioner(int sm, int par)
public DataPartitioner withSamples(int sm)
public DataPartitioner withParallelism(int par)
public DataPartitioner withPartitionType(DataPartitionType partitionType)
public DataPartitioner withImbalancePartitionId(int imbalanceId)
public DataPartitioner partition()
public java.util.HashMap<java.lang.Integer,java.lang.Integer> getDataDistribution(int par, int count, DataPartitionType partitionType)
getDataDistribution
in interface IDataPartitionFunction
public void doEquiLoad()
public void doWeightedLoad()
public void doDefaultLoad()
public void checkData(int para, int count)
public java.util.HashMap<java.lang.Integer,java.lang.Integer> getDataPartitionMap()