Package org.apache.ignite.table

Interface ContinuousQueryWatermark

All Superinterfaces:
Serializable
All Known Implementing Classes:
ContinuousQueryPhysicalTimeWatermark
public interface ContinuousQueryWatermark extends Serializable
Continuous query watermark. Represents a starting point for a continuous query.

  • Method Details

    • ofInstant

      static ContinuousQueryWatermark ofInstant(Instant startTime)
      Creates a new watermark based on specified time (wall clock).

      The specified timestamp should not be older than now() - LowWatermarkConfiguration.dataAvailabilityTime(), or the query will fail with an exception.

      For example, to query 5 seconds in the past, use Instant.now().minusSeconds(5).

      Parameters:
      startTime - Start time.
      Returns:
      Watermark.