Scala 等效于 Ruby 中的 ActiveSupport 的 Object.try

Question

try method 是核心 Ruby 的常见扩展。例如，它在 Rails 中默认可用。 try 仅在对象不是 nil（Ruby 的 null）时才在对象上执行方法或代码块。它的用法分为三种：

1. 在非nil 对象上调用方法并返回结果：
   customer_or_nil.try(:save)。

2. 如果目前的结果不是nil:
   obj.try { |non_nil_obj| do_something(non_nil_obj) }，则在表达式中链接任意代码块。

3. (2) 的扩展不用于可选处理，而是作为继续链式表达式的一种方式，其中步骤 n+1 中的方法需要一个必须根据步骤 n 的结果计算的参数：data.analyze.try { |result| result.compress(optimal_settings(result)) }.save

我对 (3) 的 Scala 等价物或替代 Scala 习惯用法特别感兴趣，例如，此代码与 Apache Spark 的DataFrame 相关：

val df = ctx.sql("select * from my_table")
df.
  repartition(max(1, df.rdd.partitions.size / 4)).
  saveAsTable("repartitioned_table")

重构为类似以下的内容（使用 Ruby 语法）

ctx.
  sql("select * from my_table").
  try { |df| df.repartition(max(1, df.rdd.partitions.size / 4)) }.
  saveAsTable("repartitioned_table")

重构的目标是通过维护单个方法链来提高可读性，并通过将df 严格限制在链中绝对需要它的步骤来减少范围污染。

注意：我对使用Option 进行可选处理的利弊讨论特别不感兴趣，因为这不是try 这个问题所关注的主要用例。

Answer 1

不在标准库中，但等价于 3 很容易编写（try 是关键字，因此重命名为 ap（apply 的缩写））：

implicit class TryOp[A](x: A) {
  def ap[B](f: A => B): B = f(x)
}

ctx.
  sql("select * from my_table").
  ap { df => df.repartition(max(1, df.rdd.partitions.size / 4)) }.
  saveAsTable("repartitioned_table")