apache-flink

3зной

1ответ

NoSuchMethod исключения Флинка при использовании набора данных с массивом пользовательского объекта

У меня есть проблема с Флинка java.lang.NoSuchMethodError: org.apache.flink.api.java.typeutils.ObjectArrayTypeInfo.getInfoFor(Lorg/apache/flink/api/common/typeinfo/TypeInformation;)Lorg/apache/flink/a

5зной

1ответ

поведения итератора в FLiNK reduceGroup

Я создаю систему, которая должна обрабатывать огромное количество данных, и мне нужно, чтобы понять, как уменьшить оператор группы работает У меня есть набор данных, где я применяю GroupBy и впоследст

1зной

1ответ

Apache Flink Channel получил событие до завершения текущей частичной записи

я прочитал CSV-файл (http://data.gdeltproject.org/events/index.html) с диска с Флинка (Java, Maven версии 8.1) и получить следующее исключение: ERROR operators.DataSinkTask: Error in user code: Channe

4зной

1ответ

Какая магия использует Flink в отдельных()? Как генерируются суррогатные ключи?

Что касается генерации суррогатного ключа, первым шагом является получение отдельного, а затем построение инкрементного ключа для каждого кортежа. Поэтому я использую Java Set для получения отдельных

6зной

2ответ

Выполнение программы Flink Sample в локальном

Я пытаюсь выполнить образец программы в Apache Flink в локальном режиме. import org.apache.flink.api.common.functions.FlatMapFunction; import org.apache.flink.api.java.DataSet; import org.apache.fli

5зной

2ответ

zipWithIndex на Apache Флинка

Я хотел бы назначить каждую строку моего входа id - который должен быть числом от 0 до N - 1, где N является количеством строк на входе. Грубо говоря, я хотел бы быть в состоянии сделать что-то вроде

4зной

2ответ

Создание объектов из входных файлов в Apache Flink

У меня есть набор данных, который структурирован по папкам и файлам. Сама структура папки/файла важна для анализа данных. Структура набора данных: folder1 +-----file11 +-----column1

3зной

2ответ

Повторное использование результатов первых вычислений во втором вычислении

Я пытаюсь написать вычисление в Flink, которое требует двух фаз. На первом этапе я начинаю с текстового файла и выполняю некоторую оценку параметров, получая в результате объект Java, представляющий с