Package | Description |
---|---|
org.apache.flink.table.descriptors |
Modifier and Type | Method and Description |
---|---|
Rowtime |
Rowtime.timestampsFromExtractor(TimestampExtractor extractor)
Deprecated.
Sets a custom timestamp extractor to be used for the rowtime attribute.
|
Rowtime |
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 |
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.
|
Rowtime |
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 |
Rowtime.watermarksFromStrategy(WatermarkStrategy strategy)
Deprecated.
Sets a custom watermark strategy to be used for the rowtime attribute.
|
Rowtime |
Rowtime.watermarksPeriodicAscending()
Deprecated.
Sets a built-in watermark strategy for ascending rowtime attributes.
|
Rowtime |
Rowtime.watermarksPeriodicBounded(long delay)
Deprecated.
Sets a built-in watermark strategy for rowtime attributes which are out-of-order by a bounded
time interval.
|
Modifier and Type | Method and Description |
---|---|
Schema |
Schema.rowtime(Rowtime rowtime)
Deprecated.
Specifies the previously defined field as an event-time attribute.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.