@Internal public interface ManagedTableFactory extends DynamicTableFactory
FactoryUtil.CONNECTOR
option.DynamicTableFactory.Context
Modifier and Type | Field and Description |
---|---|
static String |
DEFAULT_IDENTIFIER
factoryIdentifier() for the managed table factory. |
Modifier and Type | Method and Description |
---|---|
static ManagedTableFactory |
discoverManagedTableFactory(ClassLoader classLoader)
Discovers the unique implementation of
ManagedTableFactory without identifier. |
Map<String,String> |
enrichOptions(DynamicTableFactory.Context context)
Enrich options from catalog and session information.
|
default String |
factoryIdentifier()
Returns a unique identifier among same factory interfaces.
|
Map<String,String> |
onCompactTable(DynamicTableFactory.Context context,
CatalogPartitionSpec partitionSpec)
Notifies the listener that a table compaction occurred.
|
void |
onCreateTable(DynamicTableFactory.Context context,
boolean ignoreIfExists)
Notifies the listener that a table creation occurred.
|
void |
onDropTable(DynamicTableFactory.Context context,
boolean ignoreIfNotExists)
Notifies the listener that a table drop occurred.
|
forwardOptions
optionalOptions, requiredOptions
static final String DEFAULT_IDENTIFIER
factoryIdentifier()
for the managed table factory.default String factoryIdentifier()
Factory
For consistency, an identifier should be declared as one lower case word (e.g. kafka
). If multiple factories exist for different versions, a version should be appended
using "-" (e.g. elasticsearch-7
).
factoryIdentifier
in interface Factory
Map<String,String> enrichOptions(DynamicTableFactory.Context context)
void onCreateTable(DynamicTableFactory.Context context, boolean ignoreIfExists)
void onDropTable(DynamicTableFactory.Context context, boolean ignoreIfNotExists)
Map<String,String> onCompactTable(DynamicTableFactory.Context context, CatalogPartitionSpec partitionSpec)
static ManagedTableFactory discoverManagedTableFactory(ClassLoader classLoader)
ManagedTableFactory
without identifier.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.