我想从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