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

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


apache-beam google-cloud-dataflow serialization spotify-scio
person user_1357    schedule 19.09.2018    source источник

Ответы (1)


arrow_upward
2
arrow_downward

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

person Neville Li    schedule 21.09.2018