public class RepairProcedure extends ProcedureBase
-- repair all databases and tables in catalog
CALL sys.repair()
-- repair all tables in a specific database
CALL sys.repair('databaseName')
-- repair a table
CALL sys.repair('databaseName.tableName')
Modifier and Type | Field and Description |
---|---|
static String |
IDENTIFIER |
catalog
Constructor and Description |
---|
RepairProcedure() |
Modifier and Type | Method and Description |
---|---|
String[] |
call(org.apache.flink.table.procedure.ProcedureContext procedureContext,
String identifier) |
String |
identifier()
Returns a unique identifier among same factory interfaces.
|
void |
repairDatabasesOrTables(String databaseOrTables) |
execute, execute, execute, notnull, nullable, optionalConfigMap, table, withCatalog
public static final String IDENTIFIER
public String identifier()
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
).
public String[] call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String identifier) throws Catalog.DatabaseNotExistException, Catalog.TableNotExistException
public void repairDatabasesOrTables(String databaseOrTables) throws Catalog.TableNotExistException
Catalog.TableNotExistException
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.