apache-flink

1зной

1ответ

Импорт 12000 файлов в один стол

Мне нужно настроить потоковое окружение для моего проекта. Набор данных следующий: http://research.microsoft.com/pubs/152883/User_guide_T-drive.pdf Я планирую использовать PostgreSQL и Apache Кафку в

8зной

1ответ

Apache Flink vs Twitter Heron?

Есть много вопросов, связанных с Flink vs Spark Streaming, Flink vs Storm и Storm vs Heron. Происхождение этого вопроса связано с тем, что как Apache Flink, так и Twitter Heron являются истинными стру

2зной

1ответ

Как отлаживать Apache Flink?

Я работаю над расширением API Apache Flink Python, чтобы лучше соответствовать API Java, и я получаю странные ошибки о типах данных, над которыми я работаю. Есть ли способ подключить отладчик Java (на

0зной

3ответ

Flink RMQSource

Я хочу протестировать класс RMQSource для получения данных от RabbitMQ, но я не знаю, как настроить виртуальный хост Rabbit для моего обмена, и я думаю, что проблема у меня есть. Мой код: import org.a

0зной

1ответ

Погрузочно-разгрузочный процесс

У меня есть два потока. Один - поток событий, другой - поток обновления базы данных. Я хочу обогатить поток событий информацией, созданной из потока обновления БД. Поток событий очень объемный и разби

0зной

1ответ

Apache Flink для обработки конечных потоков в реальном времени

Я рассматриваю, как использовать Apache Flink для системы голосования, которую я сейчас разрабатываю. Я полный новичок для Flink, и любая помощь будет оценена. Требования: Пользователь с некоторыми пр

1зной

1ответ

Присоединяйтесь к двум потокам, используя окно с подсчетом

Я новичок в Flink Streaming API и хочу выполнить следующую простую задачу (IMO). У меня есть два потока, и я хочу присоединиться к ним, используя окна с подсчетом. Код, который у меня есть, следующий:

3зной

1ответ

Использование Apache Flink для потоковой передачи данных

Я работаю над созданием приложения с нижеследующими требованиями, и я только начинаю с flink. глотают данные в Кафки с скажем, 50 разделов (Incoming скорость - 100000 сообщ/сек) Считывает данные из Ка