Hazelcast Jet EventTimeMapper Sınıfı

Giriş

Şu satırı dahil ederiz

import com.hazelcast.jet.core.EventTimeMapper;

flatMapEvent metodu - item + partitionIndex + nativeEventTime

System.nanoTime() zamanında bir event geldiğini gösterir.

flatMapIdle metodu

Açıklaması şöyle

2. Some partition having no data

It can happen that some partition does not have any events at all while others do, or the processor doesn't get any external partitions assigned to it. If we simply wait for the timestamps in all partitions to advance to some point, we won't be emitting any watermarks. This utility supports the idle timeout: if there's no new data from a partition after the timeout elapses, it will be marked as idle, allowing the processor's watermark to advance as if that partition didn't exist. If all partitions are idle or there are no partitions, the processor will emit a special idle message and the downstream will exclude this processor from watermark coalescing.