如何将 HTTP API 公开为 Flink 源

【问题标题】：How to expose HTTP API as a Flink source如何将 HTTP API 公开为 Flink 源
【发布时间】：2021-12-15 12:53:03
【问题描述】：

我想将 HTTP API 暴露为 Java 中的 Flink 源，这样我就可以通过 HTTP 请求接收数据，向调用者返回响应并将此数据传递给下一个 Flink 运算符。

我没有找到任何关于它的文档，我也想获得它的实现示例。

【问题讨论】：

标签： java rest http apache-flink flink-streaming

【解决方案1】：

您可以使用 SourceFunction。

https://github.com/apache/flink/blob/f6d40bcfd89e67647d1f9cb41fa8be613d122494/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/functions/source/SocketTextStreamFunction.java

仅供参考

【讨论】：

猜你喜欢

1970-01-01
1970-01-01
1970-01-01
1970-01-01
2019-06-19
2022-08-20
1970-01-01
2013-10-31
1970-01-01

相关资源

下载 2021-06-05
下载 2022-12-30
下载 2022-12-01

最近更新更多

热门标签

Java Python linux javascript Mysql C# Docker 算法前端 SpringBoot Redis Vue spring 设计模式 .net core .net kubernetes c++ 数据库数据结构大数据 js 机器学习微服务 Android Go 程序员面试 JVM ASP.net core 云原生人工智能后端 PHP git CSS golang k8s Nginx Django mybatis 深度学习多线程 React 架构 devops 爬虫云计算 Spring Boot LeetCode