Что будет, если я не выставлю окно для стриминга флинков?

Что произойдет, если я напишу код, как показано ниже, и не установлю временное окно для потоковой передачи 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();
Построение конвейеров данных в реальном времени с Apache Kafka: Руководство по Python
Построение конвейеров данных в реальном времени с Apache Kafka: Руководство по Python
Apache Kafka - популярная платформа распределенной потоковой передачи данных, которую можно использовать для построения конвейеров данных в реальном...
0
0
74
1

Ответы 1

Приемник (чернила PrintER) распечатает запись сразу после получения новой записи без каких-либо задержек.

Другие вопросы по теме