List<Entity> 的数据流编码器是什么？答案

【问题标题】：What is dataflow Coder for List<Entity>?List<Entity> 的数据流编码器是什么？
【发布时间】：2017-09-19 05:04:07
【问题描述】：

目前我正在尝试覆盖“getDefaultOutputCoder”函数，它返回 ListCoder.of(EntityCoder)。 EntityCoder 无法识别。我们是否必须为此指定 CUSTOM 编码器？如果是这样，我们该怎么做？

【问题讨论】：

请不要覆盖 getDefaultOutputCoder - 它已被弃用，并将在下一个主要版本的 Beam 版本中删除。相反，在返回的 PCollection 上调用 .setCoder()（来自生成集合的转换）。
感谢您告诉我。

【解决方案1】：

ListCoder.of(SerializableCoder.of(Entity.class))

【讨论】：

感谢您提供此代码 sn-p，它可能会提供一些有限的即时帮助。一个正确的解释would greatly improve 它的长期价值通过展示为什么这是一个很好的解决问题的方法，并将使它对未来有其他类似问题的读者更有用。请edit您的回答添加一些解释，包括您所做的假设。