Вопросы по теме 'pyflink'
Apache Flink: коннектор Kafka в потоковом API Python, не удается загрузить пользовательский класс
Я пробую новый потоковый API Python от Flink и пытаюсь запустить свой скрипт с ./flink-1.6.1/bin/pyflink-stream.sh examples/read_from_kafka.py . Сценарий python довольно прост, я просто пытаюсь использовать существующую тему и отправить все в stdout...
3285 просмотров
schedule
28.02.2023
Apache-Flink 1.11 Невозможно использовать Python UDF в SQL Function DDL
Согласно этой странице слияния:
https://cwiki.apache.org/confluence/display/FLINK/FLIP-106%3A+Support+Python+UDF+in+SQL+Function+DDL
python udf во Flink 1.11 доступны для использования в функциях SQL.
Я пошел к документации flink здесь:...
369 просмотров
schedule
20.04.2022
Пользовательский источник и приемник таблицы RabbitMQ для pyflink 1.11
Согласно документам здесь:
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/
а также
https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/
Можно ли создать собственный...
138 просмотров
schedule
29.04.2022
Python Flink подключается к удаленной среде Flink
У меня есть система flink, работающая в удаленной системе ... скажем, с IP как 10.XX.XX.XX и портом как 6123. Теперь я хотел бы подключиться из другой системы, используя Pyflink, используя RemoteExecution Environment. Я видел документы...
66 просмотров
schedule
27.12.2022
