Class RemoteParForSparkWorker
- java.lang.Object
- 
- org.apache.sysds.runtime.controlprogram.parfor.ParWorker
- 
- org.apache.sysds.runtime.controlprogram.parfor.RemoteParForSparkWorker
 
 
- 
- All Implemented Interfaces:
- Serializable,- org.apache.spark.api.java.function.PairFlatMapFunction<Task,Long,String>
 
 public class RemoteParForSparkWorker extends ParWorker implements org.apache.spark.api.java.function.PairFlatMapFunction<Task,Long,String> - See Also:
- Serialized Form
 
- 
- 
Constructor SummaryConstructors Constructor Description RemoteParForSparkWorker(long jobid, String program, boolean isLocal, HashMap<String,byte[]> clsMap, boolean cpCaching, org.apache.spark.util.LongAccumulator atasks, org.apache.spark.util.LongAccumulator aiters, Map<String,org.apache.spark.broadcast.Broadcast<CacheBlock>> brInputs, boolean cleanCache, Map<String,String> lineage)
 - 
Method SummaryAll Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Iterator<scala.Tuple2<Long,String>>call(Task arg0)static voidcleanupCachedVariables(long pfid)- 
Methods inherited from class org.apache.sysds.runtime.controlprogram.parfor.ParWorkergetExecutedIterations, getExecutedTasks, getExecutionContext, getVariables
 
- 
 
- 
- 
- 
Constructor Detail- 
RemoteParForSparkWorkerpublic RemoteParForSparkWorker(long jobid, String program, boolean isLocal, HashMap<String,byte[]> clsMap, boolean cpCaching, org.apache.spark.util.LongAccumulator atasks, org.apache.spark.util.LongAccumulator aiters, Map<String,org.apache.spark.broadcast.Broadcast<CacheBlock>> brInputs, boolean cleanCache, Map<String,String> lineage)
 
- 
 
-