Публикации по теме 'apache-flink'
Использование Z-значений для эффективного вычисления k-ближайших соседей для Apache Flink
Хотите изучить Flink и другие инструменты для работы с большими данными у ведущих специалистов по обработке данных из Кремниевой долины или Нью-Йорка? Программа Insight Data Engineering Fellows Programme - это бесплатное 7-недельное профессиональное обучение, на котором вы можете создавать передовые платформы больших данных и перейти к карьере инженера данных в таких ведущих командах, как Facebook, Uber, Slack и Squarespace.
Узнать больше о программе и подать заявку сегодня ...
Вопросы по теме 'apache-flink'
Есть ли у Flink распространение по команде (похоже на Spark)
Я хочу перетасовать данные по ключу и записать данные в сток.
Я не использую group by, потому что мне не нужно делать агрегаты.
Поэтому мне интересно, есть ли у flink sql ключевое слово вроде «распространять по» в Spark.
94 просмотров
schedule
09.05.2024
сборка flink 1.10 обнаружила ошибку «пакет не найден»
Я импортирую исходный код flink в IDEA в качестве официального руководства по веб-сайту.
ошибка: org.apache.flink.sql.parser.impl не существует
описание: ошибка возникла при импорте в интерфейсе...
193 просмотров
schedule
12.05.2024
Как преобразовать строку в поток данных Apache Flink в Scala?
Я пишу скрипт Scala для обработки файла csv в Apache Flink, используя API потока данных. Мне нужно исправить формат для некоторых столбцов, а затем привести их к нужным типам.
Мой текущий код таков:
package org.myorg.tareac
import...
135 просмотров
schedule
20.04.2024
