apache-flink

2зной

2ответ

flink - кластер, не использующий кластер

Ive настроил кластер из 3 узлов, который распределял задачи (шаги? Jobs?) Довольно равномерно до самого последнего, все из которых были назначены на одну машину. Топология (мы до сих пор используют эт

6зной

1ответ

Как Apache Flink реализует Итерации?

DAG (направленный ациклический график) обычное выполнение больших данных. Мне интересно, как Apache Flink реализует Iterations. Потому что это может быть циклический граф.

1зной

1ответ

Как построить проект в ядре Apache Flink?

Я новичок в Apache Flink и не могу найти информацию о расширении ядра Flink. Я хочу начать с простого: построить в одном тестовом классе. должен ли я сохранить этот класс как jar-файл где-нибудь в fli

0зной

1ответ

apache flink: как интерпретировать вывод DataStream.print?

Я новичок в Flink, пытаясь понять, как его использовать наиболее эффективно. Я пытаюсь использовать API-интерфейсы Window, считывая из CSV-файла. Строки читать трансформируются в случае класса, таким

1зной

1ответ

Флинк - структурирование для максимальной пропускной способности

У меня есть 4 типа тем кафки и 65 тем каждого типа. Цель состоит в том, чтобы сделать некоторую простую оконную агрегацию данных и записать ее в БД. Топологии будет выглядеть примерно так: Кафка -> Ок