如果我像下面这样编写代码并且没有为 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)将在收到新记录时立即打印记录,没有任何延迟。