如果我不为 flink 流设置窗口会发生什么



如果我像下面这样编写代码并且没有为 flink kafka 流设置时间窗口会发生什么?打印间隔会是什么样的?

stream.filter(new FilterFunction<SuperLog>() {
				@Override
				public boolean filter(SuperLog superLog) throws Exception {
					return superLog.getDbtbkey().equals("aaaaa") &&
							superLog.getApp_id().equals(1L) &&
							superLog.getRule_id().equals(40048L);
				}
			}).map(new MapFunction<SuperLog, String>() {
				@Override
				public String map(SuperLog superLog) throws Exception {
					return superLog.getSip();
				}
			}).print();

接收器(PrintSink)将在收到新记录时立即打印记录,没有任何延迟。

相关内容

  • 没有找到相关文章

最新更新