我看到 Scio 回退到 Kryo 编码器而不是 Java Serializer，后者是当无法通过 CoderRegistry 推断/找到编码器时用于 Dataflow 的默认编码器。我没有看到对任何地方的任何引用setFallbackCoderProvider，Scio 如何将回退注册到 KryoAtomicCoder？
问问题
127 次
1 回答
2
直到 Scio v0.6.x 它发生在这里： https ://github.com/spotify/scio/blob/v0.6.1/scio-core/src/main/scala/com/spotify/scio/Implicits.scala# L55
自 v0.7.x 以来，编码器查找和派生发生了显着变化。它仍在大量开发中，但有关更多详细信息，请参阅： https ://github.com/spotify/scio/wiki/Coders
于 2018-09-21T07:18:18.733 回答