Как все мы знаем, Flink имеет два основных API (DataStream / DataSet), но когда я использую Flink...

Я пытаюсь зарегистрировать источник flink с помощью приведенного ниже фрагмента кода. Но произошел...

Я работаю с двумя потоками от Kafka, хотя один из них встречается не так часто. Я попытался...

У меня есть набор правил в моем BroadcastStream в Apache Flink. Я могу применять новые правила по...

У меня есть два потока Kafka: чтение с использованием API источника таблицы во Flink с...

У меня есть ошибка во Flink, которую я не понимаю. Я создал пользовательский StreamTableSource,...

Недавно мы переехали из Оракула в Кассандру. В Oracle мы активно использовали передовые...

Позвольте мне просто выразить это, я очень новичок в Flink и стараюсь как можно больше схватывать...

Я использую Flink SQL API, и я немного потерян между всеми типами 'схемы': TableSchema, Schema (из...

У меня есть некоторая конфигурация для использования и обслуживания для задания Flink. Сейчас я...

Есть ли способ использовать Broadcast Join в FLINK так же, как я использовал в SPARK. Я работаю с...

Я пытаюсь создать CEP-код с использованием flink SQL, я хотел бы начать с этого. Было бы здорово,...

Мне нужно посчитать, сколько раз в день происходит A и за 15 минут - B。 Поток может быть A1, A2, B1...

Я пытаюсь следовать документации и создать табличную функцию для "выравнивания" некоторых данных....

Это таблица: val res: Table = tenv.sqlQuery( """ |select event.ID,event.locationID,...

Я использую Flink SQL API для обработки потока данных из Kafka. Для обработки этих данных я...

Я выполняю запрос для объединения потока и таблицы, как показано ниже.Это исчерпывает пространство...

Я предоставляю пользователям интерфейс Flink SQL, поэтому я не могу использовать интерфейс Table...

У меня есть это приложение во Flink, которое использует Table API для печати данных из источника....

Я намерен зарегистрировать таблицу с БД и информацией о таблице соответственно как: tableEnv

Я использую Flink 1.8.0 и пытаюсь запросить состояние своей работы. val descriptor = new...

вопрос довольно простой, но я не смог найти ответа в интернете. У меня есть запрос Flink SQL,...

Мы создали поток данных для kafka и используем flink sql, чтобы отловить сценарий для правила...

Я пытаюсь создать источник таблицы потоков с некоторыми фиктивными данными. Когда дело доходит до...

У меня есть запрос SQL, подобный этому String ipdetailsSql = "select sid, _zpsbd6 as...