Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
HBaseDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSource |
HBaseDynamicTableFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
JdbcDynamicTableFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSource |
JdbcDynamicTableFactory.createDynamicTableSource(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 |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
AvroFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
EncodingFormat<SerializationSchema<RowData>> |
AvroFormatFactory.createEncodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions) |
Modifier and Type | Method and Description |
---|---|
DecodingFormat<DeserializationSchema<RowData>> |
CsvFormatFactory.createDecodingFormat(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 |
---|---|
DynamicTableSink |
Elasticsearch7DynamicSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSink |
Elasticsearch6DynamicSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
Modifier and Type | Method and Description |
---|---|
DynamicTableSink |
KafkaDynamicTableFactoryBase.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSource |
KafkaDynamicTableFactoryBase.createDynamicTableSource(DynamicTableFactory.Context context) |
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 | Method and Description |
---|---|
DecodingFormat<I> |
DecodingFormatFactory.createDecodingFormat(DynamicTableFactory.Context context,
ReadableConfig formatOptions)
Creates a format from the given context and format options.
|
DynamicTableSink |
PrintTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSink |
BlackHoleTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context) |
DynamicTableSink |
DynamicTableSinkFactory.createDynamicTableSink(DynamicTableFactory.Context context)
Creates a
DynamicTableSink instance from a CatalogTable and additional
context information. |
DynamicTableSource |
DataGenTableSourceFactory.createDynamicTableSource(DynamicTableFactory.Context context) |
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 and validating all options for a
DynamicTableFactory . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.