Вопросы с тегом Flink-SQL - PullRequest

Вопросы с тегом Flink-SQL

0 голосов
1 ответ

У меня есть Datastream [ObjectNode], который я прочитал как десериализованный JSON из темы Кафки....

Faizan Ahmed / 29 мая 2019
0 голосов
1 ответ

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

watercanhydrate / 20 мая 2019
0 голосов
1 ответ

Возможно ли взаимодействие с таблицей с помощью клиентского интерфейса командной строки Flink SQL,...

salc2 / 09 мая 2019
0 голосов
0 ответов

Когда я создаю 20 сообщений, я использую только 13 сообщений, остальные 7 не потребляются в режиме...

zhipengs / 21 апреля 2019
0 голосов
0 ответов

Мы знаем, что если вы хотите настроить UDF в Flink SQL, вы должны унаследовать класс ScalarFunction...

DongJiaQiang / 02 апреля 2019
1 голос
1 ответ

Как настоятельно рекомендуется в документации, я хочу добавить uid к своим операторам во Flink с...

Stevenyc091 / 02 апреля 2019
0 голосов
1 ответ

В flink sql, как проверить, является ли строка числом, как select * from input where str like...

lzh / 21 марта 2019
0 голосов
1 ответ

При использовании Flink Table SQL в моем проекте я обнаружил, что если бы в моем SQL-запросе было...

Ruoyu Dai / 19 марта 2019
1 голос
1 ответ

Я пытаюсь представить свою банку с аргами.Я использую Flink Rest Api для отправки моих аргументов в...

sky / 19 марта 2019
0 голосов
0 ответов

Я использовал приведенную ниже команду для получения рабочих мест . / Bin / flink list -r Но я хочу...

Nathon / 11 марта 2019
0 голосов
1 ответ

У меня есть неупорядоченный DataStream<Event>, который я хочу отсортировать так, чтобы...

David Anderson / 03 марта 2019
0 голосов
1 ответ

В источнике Fink есть flink-stream-java и flink-stream-scala модули.Зачем нам два модуля для...

yuyang / 25 февраля 2019
0 голосов
1 ответ

Мы рассматриваем возможность использования Flink SQL для специальной аналитики данных Кафки в...

yuyang / 16 февраля 2019
0 голосов
1 ответ

Я пытаюсь сделать экспоненциально убывающую скользящую среднюю по скользящему окну в Flink SQL.Мне...

BenoitParis / 13 февраля 2019
0 голосов
1 ответ

Теперь у нас есть SQL с причудливым управлением окнами во Flink, я пытаюсь, чтобы затухающая...

BenoitParis / 12 февраля 2019
0 голосов
1 ответ

Я следую примеру Флинка Определение функции временной таблицы , и компилятор отказывается принимать...

BenoitParis / 06 февраля 2019
0 голосов
1 ответ

Я использую Flink SQL для обработки пакета.Как я могу получить топ-n записи для каждой группы,...

Eric Zhang / 01 февраля 2019
0 голосов
1 ответ

Я создал таблицу с одним полем типа Дата, а именно f_date .Одна часть желаемой строки таблицы...

Soheil Pourbafrani / 29 января 2019
0 голосов
1 ответ

Я загрузил файл Avro в наборе данных Flink: AvroInputFormat<GenericRecord> test = new...

Soheil Pourbafrani / 28 января 2019
0 голосов
0 ответов

У меня есть работа Flink, использующая сообщения Avro от Kafka. Одно поле в Avro - это строка...

Stevenyc091 / 22 января 2019
0 голосов
1 ответ

Я пытался создать и ExternalCatalog для использования в Apache Flink Table. Я создал и добавил в...

Salvatore Rapisarda / 20 января 2019
0 голосов
1 ответ

Я успешно использую JsonRowSerializationSchema из артефакта flink-json для создания...

BenoitParis / 16 января 2019
0 голосов
0 ответов

flink sql В случае, когда оператор имеет большую ошибку в операторе: класс DataStreamCalcRule $...

Tianwang Li / 11 января 2019
0 голосов
1 ответ

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

Salvatore Rapisarda / 09 января 2019
0 голосов
1 ответ

Я обрабатываю поток Kafka с помощью Flink SQL, где каждое сообщение извлекается из Kafka,...

mjennet / 04 января 2019
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...