Constructor and Description |
---|
AsyncDynamicSinkContext(AsyncDynamicTableSinkFactory factory,
DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
BlackHoleTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource |
DataGenTableSourceFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
FileSystemTableFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSource |
FileSystemTableFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
protected <I,F extends DecodingFormatFactory<I>> |
FileSystemTableFactory.discoverDecodingFormat(DynamicTableFactory.Context context,
Class<F> formatFactoryClass) |
Modifier and Type | Method and Description |
---|---|
BulkDecodingFormat<RowData> |
BulkReaderFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a
BulkDecodingFormat from the given context and format options. |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
PrintTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
UpsertTestDynamicTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
HiveDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSource |
HiveDynamicTableFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
BulkDecodingFormat<RowData> |
AvroFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
DecodingFormat<DeserializationSchema<RowData>> |
AvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<BulkWriter.Factory<RowData>> |
AvroFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
AvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
RegistryAvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
RegistryAvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
DebeziumAvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
DebeziumAvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
BulkDecodingFormat<RowData> |
CsvFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
DecodingFormat<DeserializationSchema<RowData>> |
CsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<BulkWriter.Factory<RowData>> |
CsvFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
CsvFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
JsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
JsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
CanalJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
CanalJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
DebeziumJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
DebeziumJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
MaxwellJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
MaxwellJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
OggJsonFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
OggJsonFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
BulkDecodingFormat<RowData> |
ParquetFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<BulkWriter.Factory<RowData>> |
ParquetFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
PbFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
BulkDecodingFormat<RowData> |
PbFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
PbFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<BulkWriter.Factory<RowData>> |
PbFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
RawFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
RawFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
BulkDecodingFormat<RowData> |
OrcFileFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<BulkWriter.Factory<RowData>> |
OrcFileFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
ChangelogCsvFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
DynamicTableSource |
SocketDynamicTableFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
Modifier and Type | Class and Description |
---|---|
static class |
FactoryUtil.DefaultDynamicTableContext
Default implementation of
DynamicTableFactory.Context . |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<I> |
DecodingFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a format from the given context and format options.
|
DynamicTableSink |
DynamicTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context)
Creates a
DynamicTableSink instance from a CatalogTable and additional
context information. |
DynamicTableSource |
DynamicTableSourceFactory.createDynamicTableSource(DynamicTableFactory.Context context)
Creates a
DynamicTableSource instance from a CatalogTable and additional
context information. |
EncodingFormat<I> |
EncodingFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a format from the given context and format options.
|
static FactoryUtil.TableFactoryHelper |
FactoryUtil.createTableFactoryHelper(DynamicTableFactory factory,
DynamicTableFactory.Context context)
Creates a utility that helps in discovering formats, merging options with
getEnrichmentOptions() and validating them all for a DynamicTableFactory . |
Map<String,String> |
ManagedTableFactory.enrichOptions(DynamicTableFactory.Context context)
Deprecated.
Enrich options from catalog and session information.
|
Map<String,String> |
ManagedTableFactory.onCompactTable(DynamicTableFactory.Context context,
CatalogPartitionSpec partitionSpec)
Deprecated.
Notifies the listener that a table compaction occurred.
|
void |
ManagedTableFactory.onCreateTable(DynamicTableFactory.Context context,
boolean ignoreIfExists)
Deprecated.
Notifies the listener that a table creation occurred.
|
void |
ManagedTableFactory.onDropTable(DynamicTableFactory.Context context,
boolean ignoreIfNotExists)
Deprecated.
Notifies the listener that a table drop occurred.
|
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
TestFileSystemTableFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSource |
TestFileSystemTableFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource |
TestScanTableSourceWithWatermarkPushDownFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSource |
PythonDynamicTableFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.