Searched refs:stageInfo2 (Results 1 – 2 of 2) sorted by relevance
186 val stageInfo2 = listener.stageInfos.keys.find(_.stageId == 1).get constant187 stageInfo2.rddInfos.size should be {3} // ParallelCollectionRDD, FilteredRDD, MappedRDD188 stageInfo2.rddInfos.forall(_.numPartitions == 4) should be {true}189 stageInfo2.rddInfos.exists(_.name == "Deux") should be {true}
826 val stageInfo2 = createStageInfo(2, 3, localityPreferences2) constant827 sc.listenerBus.postToAll(SparkListenerStageSubmitted(stageInfo2))