Package | Description |
---|---|
org.apache.flink.table.descriptors | |
org.apache.flink.table.factories | |
org.apache.flink.table.sources.tsextractors | |
org.apache.flink.table.sources.wmstrategies |
Modifier and Type | Class and Description |
---|---|
class |
Rowtime
Deprecated.
This class was used for legacy connectors using
Descriptor . |
class |
Schema
Deprecated.
This class was used for legacy connectors using
Descriptor . |
Modifier and Type | Method and Description |
---|---|
static <T extends TableFactory> |
TableFactoryService.find(Class<T> factoryClass,
Descriptor descriptor)
Deprecated.
Finds a table factory of the given class and descriptor.
|
static <T extends TableFactory> |
TableFactoryService.find(Class<T> factoryClass,
Descriptor descriptor,
ClassLoader classLoader)
Deprecated.
Finds a table factory of the given class, descriptor, and classloader.
|
Modifier and Type | Class and Description |
---|---|
class |
ExistingField
|
class |
StreamRecordTimestamp
Extracts the timestamp of a StreamRecord into a rowtime attribute.
|
class |
TimestampExtractor
Deprecated.
This interface will not be supported in the new source design around
DynamicTableSource . Use the concept of computed columns instead. See FLIP-95 for more
information. |
Modifier and Type | Class and Description |
---|---|
class |
AscendingTimestamps
A watermark strategy for ascending rowtime attributes.
|
class |
BoundedOutOfOrderTimestamps
A watermark strategy for rowtime attributes which are out-of-order by a bounded time interval.
|
class |
PeriodicWatermarkAssigner
A periodic watermark assigner.
|
class |
PreserveWatermarks
A strategy which indicates the watermarks should be preserved from the underlying datastream.
|
class |
PunctuatedWatermarkAssigner
A punctuated watermark assigner.
|
class |
WatermarkStrategy
Provides a strategy to generate watermarks for a rowtime attribute.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.