Class Rowtime
- java.lang.Object
-
- org.apache.flink.table.legacy.descriptors.Rowtime
-
- All Implemented Interfaces:
Descriptor
@Deprecated @Internal public class Rowtime extends Object implements Descriptor
Deprecated.This class was used for legacy connectors usingDescriptor
.Rowtime descriptor for describing an event time attribute in the schema.
-
-
Field Summary
Fields Modifier and Type Field Description static String
ROWTIME
Deprecated.static String
ROWTIME_TIMESTAMPS_CLASS
Deprecated.static String
ROWTIME_TIMESTAMPS_FROM
Deprecated.static String
ROWTIME_TIMESTAMPS_SERIALIZED
Deprecated.static String
ROWTIME_TIMESTAMPS_TYPE
Deprecated.static String
ROWTIME_TIMESTAMPS_TYPE_VALUE_CUSTOM
Deprecated.static String
ROWTIME_TIMESTAMPS_TYPE_VALUE_FROM_FIELD
Deprecated.static String
ROWTIME_TIMESTAMPS_TYPE_VALUE_FROM_SOURCE
Deprecated.static String
ROWTIME_WATERMARKS_CLASS
Deprecated.static String
ROWTIME_WATERMARKS_DELAY
Deprecated.static String
ROWTIME_WATERMARKS_SERIALIZED
Deprecated.static String
ROWTIME_WATERMARKS_TYPE
Deprecated.static String
ROWTIME_WATERMARKS_TYPE_VALUE_CUSTOM
Deprecated.static String
ROWTIME_WATERMARKS_TYPE_VALUE_FROM_SOURCE
Deprecated.static String
ROWTIME_WATERMARKS_TYPE_VALUE_PERIODIC_ASCENDING
Deprecated.static String
ROWTIME_WATERMARKS_TYPE_VALUE_PERIODIC_BOUNDED
Deprecated.
-
Constructor Summary
Constructors Constructor Description Rowtime()
Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description Rowtime
timestampsFromExtractor(TimestampExtractor extractor)
Deprecated.Sets a custom timestamp extractor to be used for the rowtime attribute.Rowtime
timestampsFromField(String fieldName)
Deprecated.Sets a built-in timestamp extractor that converts an existingLong
orTypes.SQL_TIMESTAMP
field into the rowtime attribute.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.Map<String,String>
toProperties()
Deprecated.Converts this descriptor into a set of properties.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.Rowtime
watermarksFromStrategy(WatermarkStrategy strategy)
Deprecated.Sets a custom watermark strategy to be used for the rowtime attribute.Rowtime
watermarksPeriodicAscending()
Deprecated.Sets a built-in watermark strategy for ascending rowtime attributes.Rowtime
watermarksPeriodicBounded(long delay)
Deprecated.Sets a built-in watermark strategy for rowtime attributes which are out-of-order by a bounded time interval.
-
-
-
Field Detail
-
ROWTIME
public static final String ROWTIME
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_TIMESTAMPS_TYPE
public static final String ROWTIME_TIMESTAMPS_TYPE
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_TIMESTAMPS_TYPE_VALUE_FROM_FIELD
public static final String ROWTIME_TIMESTAMPS_TYPE_VALUE_FROM_FIELD
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_TIMESTAMPS_TYPE_VALUE_FROM_SOURCE
public static final String ROWTIME_TIMESTAMPS_TYPE_VALUE_FROM_SOURCE
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_TIMESTAMPS_TYPE_VALUE_CUSTOM
public static final String ROWTIME_TIMESTAMPS_TYPE_VALUE_CUSTOM
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_TIMESTAMPS_FROM
public static final String ROWTIME_TIMESTAMPS_FROM
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_TIMESTAMPS_CLASS
public static final String ROWTIME_TIMESTAMPS_CLASS
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_TIMESTAMPS_SERIALIZED
public static final String ROWTIME_TIMESTAMPS_SERIALIZED
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_WATERMARKS_TYPE
public static final String ROWTIME_WATERMARKS_TYPE
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_WATERMARKS_TYPE_VALUE_PERIODIC_ASCENDING
public static final String ROWTIME_WATERMARKS_TYPE_VALUE_PERIODIC_ASCENDING
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_WATERMARKS_TYPE_VALUE_PERIODIC_BOUNDED
public static final String ROWTIME_WATERMARKS_TYPE_VALUE_PERIODIC_BOUNDED
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_WATERMARKS_TYPE_VALUE_FROM_SOURCE
public static final String ROWTIME_WATERMARKS_TYPE_VALUE_FROM_SOURCE
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_WATERMARKS_TYPE_VALUE_CUSTOM
public static final String ROWTIME_WATERMARKS_TYPE_VALUE_CUSTOM
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_WATERMARKS_CLASS
public static final String ROWTIME_WATERMARKS_CLASS
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_WATERMARKS_SERIALIZED
public static final String ROWTIME_WATERMARKS_SERIALIZED
Deprecated.- See Also:
- Constant Field Values
-
ROWTIME_WATERMARKS_DELAY
public static final String ROWTIME_WATERMARKS_DELAY
Deprecated.- See Also:
- Constant Field Values
-
-
Method Detail
-
timestampsFromField
public Rowtime timestampsFromField(String fieldName)
Deprecated.Sets a built-in timestamp extractor that converts an existingLong
orTypes.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
- TheTimestampExtractor
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.
-
toProperties
public Map<String,String> toProperties()
Deprecated.Converts this descriptor into a set of properties.- Specified by:
toProperties
in interfaceDescriptor
-
-