Как Scio се връща към Kryo

Виждам, че Scio се връща към Kryo кодер, а не Java Serializer, който е кодер по подразбиране, използван за Dataflow, когато кодерът не може да бъде изведен/намерен чрез 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