如何将 CombineFn 与 getKey 一起使用

Question

我有以下代码：

PCollection<KV<String, Cell>> first = ...;

PCollection<String> lines = first
  .apply("Build lines", Combine.<String, Cell, String>perKey(new MergeCellsFn()))
;

Cell 看起来像：

public class Cell {
   public final int index;
   public final String value; 

   public Cell(int i, String value) {
      index = i;
      this.value = value;
   }
}

还有MergeCellsFn：

public class MergeCellsFn extends Combine.CombineFn<Cell, MergeCellsFn.Merger, String>

---

现在，当我尝试在上面的 apply 上编译时失败：

incompatible types: inference variable OutputT has incompatible bounds
     equality constraints: org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<java.lang.String,java.lang.String>>
     lower bounds: org.apache.beam.sdk.values.PCollection<java.lang.String>,org.apache.beam.sdk.values.POutput

我在网上只能找到一些 lambda 可能会隐式执行某些操作的地方。但是从错误消息中我不知道是什么以及如何解决这个问题，更不用说是什么问题了。

Answer 1

更改为 PCollection<KV<String, String>> lines = 会编译。