google-cloud-dataflow - 如何创建自定义编码器？

Question

我正在尝试创建一个基于AvroCoder但为 isDeterministic 返回 true 的自定义编码器 AvroDeterministicCoder 。

在我的示例数据流中，我为我的所有 PCollection 注册了这个编码器。但是，当我运行测试时，它最终会引发异常： the key coder must be deterministic for grouping.

使用我的调试器，我可以看出它使用的是编码器 AvroCoder。

在AvroDeterministicCoder中，我是否需要添加代码以使AvroDeterministicCoder反序列化为AvroDeterministicCoder 而不是 AvroCoder？

Answer 1

这是我的代码中的一个错误；我需要重写各种of方法以返回类型 AvroDeterministicCoder。

这是工作代码：AvroDeterministicCoder。