@Deprecated @Internal public class ManagedTableListener extends Object
Constructor and Description |
---|
ManagedTableListener(ClassLoader classLoader,
ReadableConfig config)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
static boolean |
isManagedTable(Catalog catalog,
CatalogBaseTable table)
Deprecated.
Check a resolved catalog table is Flink's managed table or not.
|
Map<String,String> |
notifyTableCompaction(Catalog catalog,
ObjectIdentifier identifier,
ResolvedCatalogBaseTable<?> table,
CatalogPartitionSpec partitionSpec,
boolean isTemporary)
Deprecated.
Notify compaction for managed table.
|
ResolvedCatalogBaseTable<?> |
notifyTableCreation(Catalog catalog,
ObjectIdentifier identifier,
ResolvedCatalogBaseTable<?> table,
boolean isTemporary,
boolean ignoreIfExists)
Deprecated.
Notify for creating managed table.
|
void |
notifyTableDrop(Catalog catalog,
ObjectIdentifier identifier,
ResolvedCatalogBaseTable<?> table,
boolean isTemporary,
boolean ignoreIfNotExists)
Deprecated.
Notify for dropping managed table.
|
public ManagedTableListener(ClassLoader classLoader, ReadableConfig config)
public ResolvedCatalogBaseTable<?> notifyTableCreation(@Nullable Catalog catalog, ObjectIdentifier identifier, ResolvedCatalogBaseTable<?> table, boolean isTemporary, boolean ignoreIfExists)
public void notifyTableDrop(@Nullable Catalog catalog, ObjectIdentifier identifier, ResolvedCatalogBaseTable<?> table, boolean isTemporary, boolean ignoreIfNotExists)
public Map<String,String> notifyTableCompaction(@Nullable Catalog catalog, ObjectIdentifier identifier, ResolvedCatalogBaseTable<?> table, CatalogPartitionSpec partitionSpec, boolean isTemporary)
public static boolean isManagedTable(@Nullable Catalog catalog, CatalogBaseTable table)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.