public class RemoteParForSparkWorker extends ParWorker implements org.apache.spark.api.java.function.PairFlatMapFunction<Task,Long,String>
| Constructor and Description | 
|---|
| RemoteParForSparkWorker(long jobid,
                       String program,
                       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) | 
| Modifier and Type | Method and Description | 
|---|---|
| Iterator<scala.Tuple2<Long,String>> | call(Task arg0) | 
| static void | cleanupCachedVariables(long pfid) | 
getExecutedIterations, getExecutedTasks, getExecutionContext, getVariablespublic RemoteParForSparkWorker(long jobid,
                               String program,
                               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)
Copyright © 2020 The Apache Software Foundation. All rights reserved.