Что произойдет, если я напишу код, как показано ниже, и не установлю временное окно для потоковой передачи 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();