apache-flink

0зной

1ответ

написать простой пример val env = StreamExecutionEnvironment.getExecutionEnvironment val properties = new Properties() properties.setProperty("bootstrap.servers","xxxxxx") properties.setProperty("z

1зной

1ответ

Хо, я могу провести ленивый матч с Flink CEP

Я хочу использовать FlinkCEP только для «ленивого» совпадения на шаблоне. Как я могу это сделать? , например. У меня есть входной поток ACABCABCB, и я хочу совместить с A followBy C, чтобы получить то

0зной

1ответ

Как визуализировать файлы журнала с Hadoop?

Я просто новичок в мире Big Data, поэтому не знаю, как создать приложение панели мониторинга для визуализации данных из файлов журналов в Hadoop. После поиска вокруг, я могу думать о некотором решении

2зной

1ответ

Использование JNI во флинге Задачи кластера YARN

У меня есть приложение, которое отправляет задания Apache Flink в кластер AWS Elastic MapReduce YARN через API scala RemoteExecutionEnvironment. Эти задания используют JNI для выполнения части своих в

1зной

1ответ

Флинк: нет внешних соединений в DataStream?

Я с удивлением обнаружил, что нет внешних соединений для DataStream в Flink (DataStream docs). Для DataSet у вас есть все возможности: leftOuterJoin, rightOuterJoin и fullOuterJoin, помимо регулярного

2зной

1ответ

экранировать кавычки внутри поля в кавычках при разборе CSV в Флинка

В Флинка, разбор файла CSV с помощью readCsvFile вызывает исключение при encountring поля, содержащие цитаты как "Fazenda São José ""OB"" Airport": org.apache.flink.api.common.io.ParseException: Line

0зной

1ответ

Apache Flink - groupBy

Я пытаюсь выполнить первое упражнение на http://dataartisans.github.io/flink-training/exercises/. Теперь я прихожу к следующей проблеме. Что возвращает функция groupBy? И как метод foldLeft преобразуе

0зной

1ответ

Можно ли регистрироваться через Flink Python API

Я просмотрел код docs, образец кода и группы пользователей, но я не могу понять это.