public class DCSparkScheme extends DataPartitionSparkScheme
For each row, find out the shifted place according to the workerID indicator
| Modifier and Type | Method and Description |
|---|---|
org.apache.sysds.runtime.controlprogram.paramserv.dp.DataPartitionSparkScheme.Result |
doPartitioning(int numWorkers,
int rblkID,
MatrixBlock features,
MatrixBlock labels) |
public org.apache.sysds.runtime.controlprogram.paramserv.dp.DataPartitionSparkScheme.Result doPartitioning(int numWorkers,
int rblkID,
MatrixBlock features,
MatrixBlock labels)
doPartitioning in class DataPartitionSparkSchemeCopyright © 2021 The Apache Software Foundation. All rights reserved.