【发布时间】：2015-01-25 17:37:45
【问题描述】：
我正在尝试创建一个自定义编码器 AvroDeterministicCoder，它基于 AvroCoder，但对于 isDeterministic 返回 true。
在我的example Dataflow 中，我为我的所有 PCollections 注册了这个编码器。但是，当我运行 test 时，它最终会引发异常：
the key coder must be deterministic for grouping.
使用我的调试器，我可以看出它使用的是编码器 AvroCoder。
在AvroDeterministicCoder 中是否需要添加代码以使AvroDeterministicCoder 反序列化为AvroDeterministicCoder 而不是AvroCoder？
【问题讨论】：
-
我想我忘了重写 of 方法，所以它返回了一个 AvroCoder。