Package | Description |
---|---|
org.apache.flink.table.descriptors | |
org.apache.flink.table.sources | |
org.apache.flink.table.sources.tsextractors |
Modifier and Type | Method and Description |
---|---|
static Optional<Tuple2<TimestampExtractor,WatermarkStrategy>> |
RowtimeValidator.getRowtimeComponents(DescriptorProperties properties,
String prefix)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Rowtime |
Rowtime.timestampsFromExtractor(TimestampExtractor extractor)
Deprecated.
Sets a custom timestamp extractor to be used for the rowtime attribute.
|
Modifier and Type | Method and Description |
---|---|
TimestampExtractor |
RowtimeAttributeDescriptor.getTimestampExtractor()
Deprecated.
Returns the [[TimestampExtractor]] for the attribute.
|
Constructor and Description |
---|
RowtimeAttributeDescriptor(String attributeName,
TimestampExtractor timestampExtractor,
WatermarkStrategy watermarkStrategy)
Deprecated.
|
Modifier and Type | Class and Description |
---|---|
class |
ExistingField
Deprecated.
This class will not be supported in the new source design around
DynamicTableSource . See FLIP-95 for more
information. |
class |
StreamRecordTimestamp
Deprecated.
This class will not be supported in the new source design around
DynamicTableSource . See FLIP-95 for more
information. |
Modifier and Type | Method and Description |
---|---|
static ResolvedFieldReference[] |
TimestampExtractorUtils.getAccessedFields(TimestampExtractor timestampExtractor,
DataType physicalInputType,
Function<String,String> nameRemapping)
Retrieves all field accesses needed for the given
TimestampExtractor . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.