链式应用返回类型似乎在编译时确定

Question

谁能给我解释一下下面几行代码：

import org.apache.beam.sdk.Pipeline;
[..]
Pipeline p = Pipeline.create(options);
p.apply(TextIO.read().from("gs://apache-beam-samples/shakespeare/*"))
.apply("ExtractWords", ParDo.of(new DoFn<String, String>() {/* etc */}

我不明白为什么会这样编译。 Pipeline 中的 Apply 方法返回一个 T extends POutput。 接口 POutput 没有任何 apply 方法。

在这种情况下，TextIO.read().from(...) 恰好返回一个 PCollection 作为 POutput，并且 THAT 有一个 apply 方法。

但就 Pipeline 合约而言，我们知道只会返回一个 POutput。 那么编译器如何检查传递给第一个 apply 的参数类型呢？根据我在编写 Java 时的记忆，这只能在运行时看到。

Answer 1

签名是：

public <OutputT extends POutput> OutputT apply(
    String name, PTransform<? super PBegin, OutputT> root) {
  ...
}

这意味着，对于扩展POutput 的任何可能的类型OutputT，此方法适用于(String, PTransform<? super PBegin, OutputT>) 并返回OutputT。

TextIO.read() 返回一个扩展PTransform<PBegin, PCollection<String>> 的TextIO.Read；它匹配PTransform<? super PBegin, OutputT>:

• PBegin 类型实际上是 PBegin 的超类型
• PCollection<String> 类型扩展 POutput

因此，.apply() 方法适用，替换为 OutputT = PCollection<String>。将OutputT的实际值代入.apply()的签名后，返回值为PCollection<String>。

你所说的（OutputT 被POutput 替换）发生在类型擦除 - Pipeline.apply() 的类型擦除签名是POutput apply(String, PTransform)；这就是它在编译后的Pipeline 字节码中的签名，就JVM 而言，在实际执行它时。然而，类型擦除发生在类型检查之后，而不是之前 - 否则几乎所有使用泛型的 Java 程序都将无法编译。

这与调用 Arrays.asList(1, 2, 3) 时发生的事情完全相同 - 它返回 List<Integer> 而不是 List<Object> 或 List，即使类型擦除的签名是 List asList(Object[])。