java—在ApacheFlink中获取json数据作为输入流

vsnjm48y  于 2021-06-24  发布在  Flink
关注(0)|答案(1)|浏览(433)

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

ktecyv1j

ktecyv1j1#

您可以使用 socketTextStream 来源。
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-来源

相关问题