我想知道以下简短的片段,确实显示重复可以使更多干.我似乎经常遇到这种结构.
假设我想要在运行时选择同步或异步的某些计算.
for(i <- 1 to reps) {
Thread.sleep(expDistribution.sample().toInt)
if (async) {
Future {
sqlContext.sql(query).collect()
}
} else {
sqlContext.sql(query).collect()
}
}
Run Code Online (Sandbox Code Playgroud)
重复调用sqlContext会感觉很笨拙.这个琐碎的重复构造有成语吗?
您可以将计算"存储"在本地def,然后同步或异步地评估它
def go = sqlContext.sql(query).collect()
if(async) Future(go) else Future.successful(go)
Run Code Online (Sandbox Code Playgroud)
| 归档时间: |
|
| 查看次数: |
111 次 |
| 最近记录: |