我想从一个url获取json数组形式的输入流。如何设置源代码，以便在apache flink中使用datastream连续获取输入。简而言之，我希望在不关闭flink作业的情况下从url连续获取json数据。
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-来源
socketTextStream
1条答案
按热度按时间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-来源