public class TableStoreManagedFactory extends AbstractTableStoreFactory implements org.apache.flink.table.factories.ManagedTableFactory
ManagedTableFactory
.Constructor and Description |
---|
TableStoreManagedFactory() |
Modifier and Type | Method and Description |
---|---|
Map<String,String> |
enrichOptions(org.apache.flink.table.factories.DynamicTableFactory.Context context) |
Map<String,String> |
onCompactTable(org.apache.flink.table.factories.DynamicTableFactory.Context context,
org.apache.flink.table.catalog.CatalogPartitionSpec catalogPartitionSpec) |
void |
onCreateTable(org.apache.flink.table.factories.DynamicTableFactory.Context context,
boolean ignoreIfExists) |
void |
onDropTable(org.apache.flink.table.factories.DynamicTableFactory.Context context,
boolean ignoreIfNotExists) |
createDynamicTableSink, createDynamicTableSource, optionalOptions, requiredOptions
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
discoverManagedTableFactory, factoryIdentifier
public Map<String,String> enrichOptions(org.apache.flink.table.factories.DynamicTableFactory.Context context)
enrichOptions
in interface org.apache.flink.table.factories.ManagedTableFactory
public void onCreateTable(org.apache.flink.table.factories.DynamicTableFactory.Context context, boolean ignoreIfExists)
onCreateTable
in interface org.apache.flink.table.factories.ManagedTableFactory
public void onDropTable(org.apache.flink.table.factories.DynamicTableFactory.Context context, boolean ignoreIfNotExists)
onDropTable
in interface org.apache.flink.table.factories.ManagedTableFactory
Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.