public class DataPartitionerSparkMapper extends Object implements org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<Long,scala.Tuple2<MatrixBlock,MatrixBlock>>,Integer,scala.Tuple2<Long,scala.Tuple2<MatrixBlock,MatrixBlock>>>, Serializable
| Constructor and Description | 
|---|
| DataPartitionerSparkMapper(Statement.PSScheme scheme,
                          int workersNum,
                          SparkExecutionContext sec,
                          int numEntries) | 
| Modifier and Type | Method and Description | 
|---|---|
| Iterator<scala.Tuple2<Integer,scala.Tuple2<Long,scala.Tuple2<MatrixBlock,MatrixBlock>>>> | call(scala.Tuple2<Long,scala.Tuple2<MatrixBlock,MatrixBlock>> input)Do data partitioning | 
public DataPartitionerSparkMapper(Statement.PSScheme scheme, int workersNum, SparkExecutionContext sec, int numEntries)
public Iterator<scala.Tuple2<Integer,scala.Tuple2<Long,scala.Tuple2<MatrixBlock,MatrixBlock>>>> call(scala.Tuple2<Long,scala.Tuple2<MatrixBlock,MatrixBlock>> input) throws Exception
call in interface org.apache.spark.api.java.function.PairFlatMapFunction<scala.Tuple2<Long,scala.Tuple2<MatrixBlock,MatrixBlock>>,Integer,scala.Tuple2<Long,scala.Tuple2<MatrixBlock,MatrixBlock>>>input - RowBlockID => (features, labels)Exception - Some exceptionCopyright © 2020 The Apache Software Foundation. All rights reserved.