如果我不设置flink流媒体的窗口会发生什么?

6kkfgxo0  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(473)

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

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();
ioekq8ef

ioekq8ef1#

接收到新记录时,接收器(printsink)会立即打印记录,不会有任何延迟。

相关问题