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, getVariables
public 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.