Modifier and Type | Class and Description |
---|---|
class |
CatalogTableBuilder
A builder for creating a
CatalogTable . |
Modifier and Type | Class and Description |
---|---|
class |
Avro
Format descriptor for Apache Avro records.
|
class |
BatchTableDescriptor
Describes a table connected from a batch environment.
|
class |
ClassInstance
Descriptor for a class instance.
|
class |
ConnectorDescriptor
Describes a connector to an other system.
|
class |
ConnectTableDescriptor
Describes a table connected from
TableEnvironment.connect(ConnectorDescriptor) . |
class |
CoreModuleDescriptor
Module descriptor for
CoreModule . |
class |
Csv
Format descriptor for comma-separated values (CSV).
|
class |
CustomConnectorDescriptor
Describes a custom connector to an other system.
|
class |
DescriptorBase
Base class for
Descriptor s. |
class |
Elasticsearch
Connector descriptor for the Elasticsearch search engine.
|
class |
FileSystem
Connector descriptor for a file system.
|
class |
FormatDescriptor
Describes the format of data.
|
class |
FunctionDescriptor
Descriptor for describing a function.
|
class |
HBase
Connector descriptor for Apache HBase.
|
class |
HierarchyDescriptor
A descriptor that may exist in an arbitrary level (be recursively included by other descriptors).
|
class |
Json
Format descriptor for JSON.
|
class |
Kafka
Connector descriptor for the Apache Kafka message queue.
|
class |
LiteralValue
Descriptor for a literal value.
|
class |
ModuleDescriptor
Describes a
Module . |
class |
OldCsv
Deprecated.
Use the RFC-compliant
Csv format in the dedicated flink-formats/flink-csv
module instead when writing to Kafka. |
class |
Rowtime
Rowtime descriptor for describing an event time attribute in the schema.
|
class |
Schema
Describes a schema of a table.
|
class |
StreamTableDescriptor
Describes a table connected from a streaming environment.
|
class |
TableDescriptor<D extends TableDescriptor<D>>
Describes a table consisting of a connector (in a given update mode) and a format.
|
Modifier and Type | Class and Description |
---|---|
class |
CustomFormatDescriptor
Describes the custom format of data.
|
Modifier and Type | Method and Description |
---|---|
static <T extends TableFactory> |
TableFactoryService.find(Class<T> factoryClass,
Descriptor descriptor)
Finds a table factory of the given class and descriptor.
|
static <T extends TableFactory> |
TableFactoryService.find(Class<T> factoryClass,
Descriptor descriptor,
ClassLoader classLoader)
Finds a table factory of the given class, descriptor, and classloader.
|
Modifier and Type | Class and Description |
---|---|
class |
HiveModuleDescriptor
Module descriptor for
HiveModule . |
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 which only works with the Blink planner. 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–2022 The Apache Software Foundation. All rights reserved.