本文整理了Java中org.apache.spark.broadcast.Broadcast.unpersist()
方法的一些代码示例,展示了Broadcast.unpersist()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Broadcast.unpersist()
方法的具体详情如下:
包路径:org.apache.spark.broadcast.Broadcast
类名称:Broadcast
方法名:unpersist
暂无
代码示例来源:origin: OryxProject/oryx
bUserIDToIndex.unpersist();
bItemIDToIndex.unpersist();
代码示例来源:origin: OryxProject/oryx
trainingRatingDataRDD.unpersist(false);
bUserIDToIndex.unpersist();
bItemIDToIndex.unpersist();
unpersist(model);
bUserIndexToID.unpersist();
bItemIndexToID.unpersist();
代码示例来源:origin: org.apache.beam/beam-runners-spark
public void unpersist() {
this.bcast.unpersist();
}
代码示例来源:origin: locationtech/geowave
public void reindex(final Broadcast<? extends NumericIndexStrategy> newIndexStrategy) {
// Remove original indexing strategy
if (indexStrategy != null) {
indexStrategy.unpersist();
}
indexStrategy = (Broadcast<NumericIndexStrategy>) newIndexStrategy;
reset();
}
内容来源于网络,如有侵权,请联系作者删除!