org.apache.spark.broadcast.Broadcast.unpersist()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(1.0k)|赞(0)|评价(0)|浏览(203)

本文整理了Java中org.apache.spark.broadcast.Broadcast.unpersist()方法的一些代码示例,展示了Broadcast.unpersist()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Broadcast.unpersist()方法的具体详情如下:
包路径:org.apache.spark.broadcast.Broadcast
类名称:Broadcast
方法名:unpersist

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();
}

相关文章