Class Rowtime

    • Constructor Detail

      • Rowtime

        public Rowtime()
        Deprecated.
    • Method Detail

      • timestampsFromField

        public Rowtime timestampsFromField​(String fieldName)
        Deprecated.
        Sets a built-in timestamp extractor that converts an existing Long or Types.SQL_TIMESTAMP field into the rowtime attribute.
        Parameters:
        fieldName - The field to convert into a rowtime attribute.
      • timestampsFromSource

        public Rowtime timestampsFromSource()
        Deprecated.
        Sets a built-in timestamp extractor that converts the assigned timestamps from a DataStream API record into the rowtime attribute and thus preserves the assigned timestamps from the source.

        Note: This extractor only works in streaming environments.

      • timestampsFromExtractor

        public Rowtime timestampsFromExtractor​(TimestampExtractor extractor)
        Deprecated.
        Sets a custom timestamp extractor to be used for the rowtime attribute.
        Parameters:
        extractor - The TimestampExtractor to extract the rowtime attribute from the physical type.
      • watermarksPeriodicAscending

        public Rowtime watermarksPeriodicAscending()
        Deprecated.
        Sets a built-in watermark strategy for ascending rowtime attributes.

        Emits a watermark of the maximum observed timestamp so far minus 1. Rows that have a timestamp equal to the max timestamp are not late.

      • watermarksPeriodicBounded

        public Rowtime watermarksPeriodicBounded​(long delay)
        Deprecated.
        Sets a built-in watermark strategy for rowtime attributes which are out-of-order by a bounded time interval.

        Emits watermarks which are the maximum observed timestamp minus the specified delay.

        Parameters:
        delay - delay in milliseconds
      • watermarksFromSource

        public Rowtime watermarksFromSource()
        Deprecated.
        Sets a built-in watermark strategy which indicates the watermarks should be preserved from the underlying DataStream API and thus preserves the assigned watermarks from the source.
      • watermarksFromStrategy

        public Rowtime watermarksFromStrategy​(WatermarkStrategy strategy)
        Deprecated.
        Sets a custom watermark strategy to be used for the rowtime attribute.