Modifier and Type | Class and Description |
---|---|
class |
CatalogTableBuilder
A builder for creating a
CatalogTable . |
class |
ExternalCatalogTable
Deprecated.
use
CatalogTable instead. |
Modifier and Type | Class and Description |
---|---|
class |
HiveCatalogDescriptor
Catalog descriptor for
HiveCatalog . |
Modifier and Type | Interface and Description |
---|---|
interface |
SchematicDescriptor<D extends SchematicDescriptor<D>>
Deprecated.
This class can be dropped once we remove external catalog support.
|
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 |
CatalogDescriptor
Describes a catalog of tables, views, and functions.
|
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 |
Csv
Format descriptor for comma-separated values (CSV).
|
class |
DescriptorBase
Base class for
Descriptor s. |
class |
Elasticsearch
Connector descriptor for the Elasticsearch search engine.
|
class |
ExternalCatalogDescriptor
Deprecated.
use
CatalogDescriptor instead. |
class |
FileSystem
Connector descriptor for a file system.
|
class |
FormatDescriptor
Describes the format of data.
|
class |
FunctionDescriptor
Descriptor for describing a function.
|
class |
GenericInMemoryCatalogDescriptor
Catalog descriptor for the generic in memory catalog.
|
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 |
Metadata
Metadata descriptor for adding additional, useful information.
|
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 |
Statistics
Statistics descriptor for describing table stats.
|
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 |
CustomConnectorDescriptor
Describes a custom connector to an other system.
|
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.
|
static ExternalCatalog |
TableFactoryUtil.findAndCreateExternalCatalog(Descriptor descriptor)
Deprecated.
|
static <T> TableSink<T> |
TableFactoryUtil.findAndCreateTableSink(Descriptor descriptor)
Returns a table sink matching the descriptor.
|
static <T> TableSource<T> |
TableFactoryUtil.findAndCreateTableSource(Descriptor descriptor)
Returns a table source matching the descriptor.
|
Modifier and Type | Class and Description |
---|---|
class |
ExistingField
|
class |
StreamRecordTimestamp
Extracts the timestamp of a StreamRecord into a rowtime attribute.
|
class |
TimestampExtractor
Provides an expression to extract the timestamp for a rowtime attribute.
|
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–2020 The Apache Software Foundation. All rights reserved.