apache-flink

4зной

1ответ

Есть ли что-то похожее на Mahout's XmlInputFormat, но для Flink? У меня есть большой XML-файл, и я хочу извлечь определенные элементы. В моем случае это дамп википедии, и мне нужно получить все теги <

4зной

2ответ

Проверка соответствия файлов csv произвольному порядку строк (Junit)

Я разрабатываю проект с Apache Flink, и я использую junit для тестирования своих операторов. Однако я столкнулся с проблемой: из-за параллелизма, flink будет записывать свой выходной файл csv с «случа

10зной

1ответ

Flink Scala API «не хватает аргументов»

У меня возникли проблемы с использованием Apache Flink Scala API Например, даже когда я беру примеры из официальной документации, то компилятор Scala дает мне тонны ошибок компиляции. Код: object Test

2зной

1ответ

Функции API Flink Scala по общим параметрам

Это вопрос следующего содержания: Flink Scala API "not enough arguments". Хотелось бы пройти мимо Flink's DataSet и сделать что-то с ним, но параметры набора данных являются общими. Вот проблема у мен

0зной

1ответ

Интеграция структурированных и неструктурированных данных с крупномасштабным процессором обработки данных

Как механизм обработки данных, такой как Spark, apache flink, объединяет структурированные, полуструктурированные и неструктурированные данные и влияет на вычисления?

23зной

1ответ

Apache Flink vs Apache Spark как платформы для крупномасштабного машинного обучения?

Может ли кто-нибудь сравнить Flink и Spark как платформы для машинного обучения? Что потенциально лучше для итеративных алгоритмов? Ссылка на общее обсуждение Flink vs Spark: What is the difference be

7зной

2ответ

Как Apache Flink сравнивается с Mapreduce на Hadoop?

Как Apache Flink сравнивается с Mapreduce на Hadoop? Каким образом это лучше и почему?