Class RemoteParForSparkWorker

    • Constructor Detail

      • RemoteParForSparkWorker

        public 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 Detail

      • cleanupCachedVariables

        public static void cleanupCachedVariables​(long pfid)