在 apache flink 中获取 JSON 数据作为输入流



我想从URL获取JSON数组形式的输入流。如何设置源代码,以便使用数据流在 apache flink 中连续获取输入。简而言之,我想在不关闭 flink 作业的情况下从 url 连续获取 json 数据。

您可以使用

socketTextStream源连续获取 JSON 字符串化对象流。

Flink 套接字示例:https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java

有关数据源的更多信息:https://ci.apache.org/projects/flink/flink-docs-master/dev/datastream_api.html#data-sources

相关内容

  • 没有找到相关文章

最新更新