apache-flink

Я создал очень простую задачу Apache Beam для тестирования, она написана на scala и выглядит так: object Test { def main(args: Array[String]): Unit = { val options =…