Class RemoteDPParForSparkWorker
- java.lang.Object
- 
- org.apache.sysds.runtime.controlprogram.parfor.ParWorker
- 
- org.apache.sysds.runtime.controlprogram.parfor.RemoteDPParForSparkWorker
 
 
- 
- All Implemented Interfaces:
- Serializable,- org.apache.spark.api.java.function.PairFlatMapFunction<Iterator<scala.Tuple2<Long,Iterable<org.apache.hadoop.io.Writable>>>,Long,String>
 
 public class RemoteDPParForSparkWorker extends ParWorker implements org.apache.spark.api.java.function.PairFlatMapFunction<Iterator<scala.Tuple2<Long,Iterable<org.apache.hadoop.io.Writable>>>,Long,String> - See Also:
- Serialized Form
 
- 
- 
Constructor SummaryConstructors Constructor Description RemoteDPParForSparkWorker(String program, boolean isLocal, HashMap<String,byte[]> clsMap, String inputVar, String iterVar, boolean cpCaching, DataCharacteristics mc, boolean tSparseCol, ParForProgramBlock.PartitionFormat dpf, Types.FileFormat fmt, org.apache.spark.util.LongAccumulator atasks, org.apache.spark.util.LongAccumulator aiters)
 - 
Method SummaryAll Methods Instance Methods Concrete Methods Modifier and Type Method Description Iterator<scala.Tuple2<Long,String>>call(Iterator<scala.Tuple2<Long,Iterable<org.apache.hadoop.io.Writable>>> arg0)- 
Methods inherited from class org.apache.sysds.runtime.controlprogram.parfor.ParWorkergetExecutedIterations, getExecutedTasks, getExecutionContext, getVariables
 
- 
 
- 
- 
- 
Constructor Detail- 
RemoteDPParForSparkWorkerpublic RemoteDPParForSparkWorker(String program, boolean isLocal, HashMap<String,byte[]> clsMap, String inputVar, String iterVar, boolean cpCaching, DataCharacteristics mc, boolean tSparseCol, ParForProgramBlock.PartitionFormat dpf, Types.FileFormat fmt, org.apache.spark.util.LongAccumulator atasks, org.apache.spark.util.LongAccumulator aiters) 
 
- 
 
-