org.apache.flink.table.descriptors

Class Rowtime

java.lang.Object

org.apache.flink.table.descriptors.Rowtime

All Implemented Interfaces:

Descriptor

Deprecated.

This class was used for legacy connectors using Descriptor.

@PublicEvolving
 @Deprecated
public class Rowtime
extends Object
implements Descriptor

Rowtime descriptor for describing an event time attribute in the schema.

Field Summary

Fields

Modifier and Type	Field and 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 and Description
Rowtime() Deprecated.

Method Summary

Modifier and Type	Method and 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 existing Long or Types.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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

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.

toProperties

public Map<String,String> toProperties()

Deprecated.

Converts this descriptor into a set of properties.

Specified by:

toProperties in interface Descriptor