深入理解Spark:核心思想与源码分析. 3.14 将SparkContext标记为激活
2023-03-09 22:24:48 时间
3.14 将SparkContext标记为激活
SparkContext初始化的最后将当前SparkContext的状态从contextBeingConstructed(正在构建中)改为activeContext(已激活),代码如下。
SparkContext.setActiveContext(this, allowMultipleContexts)
setActiveContext方法的实现如下。
private[spark] def setActiveContext(
sc: SparkContext,
allowMultipleContexts: Boolean): Unit = {
SPARK_CONTEXT_CONSTRUCTOR_LOCK.synchronized {
assertNoOtherContextIsRunning(sc, allowMultipleContexts)
contextBeingConstructed = None
activeContext = Some(sc)
}
}
相关文章
- Can‘t read file : End of file found 文件:txn_current、current svn无法正常读取文件
- 单细胞基因组测序看拷贝数变异就足够了
- “adb”不是内部或外部命令,也不是可运行的程序或批处理文件
- 人类远端肺部气道细胞图谱绘制
- Could not get unknown property ‘versions‘ for object of type com.android.build.gradle.AppExtension
- 单细胞meta分析揭示肿瘤反应性CXCL13+T细胞对免疫检查点阻断的反应
- InstantRun mode is not supported
- 单细胞RNA-seq分析小鼠肺动脉高压内皮细胞
- 2022单细胞关键意见领袖的关键文章
- android studio3.6版本配置svn忽略文件
- Gradle sync failed: Could not read cache value from C:\Users\lenovo\.gradle\daemon\4.1\registry.bin
- CAF里也有好人-使用CD105明辨好坏CAF
- android:screenOrientation=“portrait“ 一直警告报红
- 复杂组织中单细胞表观基因组的空间分辨方法
- scRNA-seq 揭示UCOGCP的发生与异质性
- 先天性心内膜缺陷导致左心发育不良综合征
- 前列腺癌进展过程中单细胞分辨率下的细胞群体动力学研究
- Manifest merger failed : Attribute application@appComponentFactory value=(android.support.v4.app.C
- C盘空间一直在减小(每隔几秒减少0.1),windows文件夹下temp文件夹删除后一直在重复创建
- Cause: buildOutput.apkData must not be null