Согласно документации Apache Beam, я могу найти кодировщики для конкретных типов данных, а также настраиваемые кодеры. Это дает возможность создавать собственные кодировщики путем регистрации в реестре кода. Но…
apache-beam-io
Я создал очень простую задачу Apache Beam для тестирования, она написана на scala и выглядит так: object Test { def main(args: Array[String]): Unit = { val options =…