THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||
|---|---|---|---|---|
| ||||
DESCRIBE TABLE EXTENDED [catalog_name.][db_name.]table_name [PARTITION partition_spec] |
DESCRIBE DETAIL TABLE EXTENDED output:
name | type | description | |||
name | String | catalog.database.tableName | |||
log.kafka.bootstrap.servers | Map | Kafka brokers | |||
log.retention | Duration | how long changes log will be kept | |||
file.path | String | File path | |||
log.kafka.topic | String | topic of Kafka | watermark | Timestamp | Watermark of the latest written data (If table defines watermark) |
file.format | String | format for file | |||
bucket | Integer | bucket number | |||
change-tracking | Boolean | does this table tracking changes |
...
name | type | description | |||
partition | String | partition spec | |||
file.path | String | path of this partition | last-modified | Timestamp | last modified time |
num-files | Integer | file number |
...
We need an interface to discover the managed table factory implementation when there is no "connector=..." optionfor managed table:
| Code Block | ||||
|---|---|---|---|---|
| ||||
/**
* Base interface for configuring a managed dynamic table connector. The managed table factory is
* used when there is no {@link FactoryUtil#CONNECTOR} option.
*/
@Internal
public interface ManagedTableFactory extends DynamicTableFactory {
@Override
default String factoryIdentifier() {
return "";
}
/**
* Enrich options from catalog and session information.
*
* @return new options of this table.
*/
Map<String, String> enrichOptions(Context context);
/** Notifies the listener that a table creation occurred. */
void onCreateTable(Context context);
/** Notifies the listener that a table drop occurred. */
void onDropTable(Context context);
} |
...
- Key:
- Without primary key: key is null.
- With primary key: key is json format by default. This is controlled by 'log.pk.key-format'.
- Value: Use debezium-json to storerecord with or without declaration primary key by default. This is controlled by 'log.format'.
...