Как Scio возвращается к Крио

Question

Я вижу, что Scio отказывается от кодера Kryo, а не от Java Serializer, который является кодером по умолчанию, используемым для потока данных, когда кодер не может быть выведен / найден через CoderRegistry.Я не вижу нигде ссылки на setFallbackCoderProvider, как Scio регистрирует откат к KryoAtomicCoder?

Answer 1

До 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