В настоящее время я использую Apache Spark 2.3.2 и создаю конвейер для чтения потоковых csv-файлов...