Hi, IngestionTime is usually used when the records don't have a proper event time associated with it, but the job has a long topology, and users want to persist the (time)order of events as they arrive in the system. In that sense, you can use the regular event time watermark strategies also for ingestion time. Afaik ingestion time is rarely used in practice.
On Tue, Apr 5, 2022 at 12:10 AM Xinbin Huang <b...@apache.org> wrote: > Hi, > > Since *TimeCharacteristic,* is deprecated. > > AFAIK, > - TimeCharacteristic*.*ProcessingTime -> WatermarkStrategy.noWatermarks() > - TimeCharacteristic*.*EventTime -> > WatermarkStrategy.forBoundedOutOfOrderness(<Duration>) > - TimeCharacteristic*.*IngestionTime -> ??? > > Do we have a built-in *WatermarkStrategy *equivalent for the purpose? > > Thanks > Bin > >
