apache-flink

0зной

1ответ

Извлечение первых элементов из нескольких отсортированных разделов

Я хочу читать несколько файлов, подсчитывать повторяющиеся строки, сортировать строки по количеству повторений, принимать 10 самых повторяющихся строк. lines = env.readTextFile("logs-dir") tuples = l

0зной

1ответ

Как реализовать foreach в flink?

Мне нужно использовать foreach в flink. Есть ли кто-нибудь, кто может показать пример о том, как использовать карту() в flink для реализации foreach в искрах?

4зной

1ответ

Название динамической таблицы в Cassandra Pojo Sink Flink

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

5зной

1ответ

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

Я пытаюсь построить пример приложения, используя Apache Flink, который делает следующее: Считывает поток символов акций (например, 'CSCO', 'FB') из очереди Kafka. Для каждого символа в реальном времен

0зной

2ответ

Apache Flink чтение Avro байт [] от Кафки

В рассматривающих примерах, которые я вижу много это: FlinkKafkaConsumer08<Event> kafkaConsumer = new FlinkKafkaConsumer08<>("myavrotopic", avroSchema, properties); я вижу, что они здесь уже знают с

0зной

1ответ

Ошибка Flink: java.lang.ClassNotFoundException: org.apache.flink.shaded.calcite.com.google.common.base.Throwables

Я использую Flink для потоковой передачи данных, хранящихся в файле csv. Я хочу поместить его в формат таблицы с определенной схемой. Для этого я использую Flink-table_2.10-1.1.3.jar (таблица АНП), но

2зной

2ответ

Flink: Jar файл не содержит основной класса

При попытке выполнить работу Flink, у меня есть сообщение об ошибке: org.apache.flink.client.program.ProgramInvocationException: Neither a 'Main-Class', nor a 'program-class' entry was found in the ja