public class CompactDatabaseProcedure extends ProcedureBase
-- NOTE: use '' as placeholder for optional arguments
-- compact all databases
CALL sys.compact_database()
-- compact some databases (accept regular expression)
CALL sys.compact_database('includingDatabases')
-- set compact mode
CALL sys.compact_database('includingDatabases', 'mode')
-- compact some tables (accept regular expression)
CALL sys.compact_database('includingDatabases', 'mode', 'includingTables')
-- exclude some tables (accept regular expression)
CALL sys.compact_database('includingDatabases', 'mode', 'includingTables', 'excludingTables')
-- set table options ('k=v,...')
CALL sys.compact_database('includingDatabases', 'mode', 'includingTables', 'excludingTables', 'tableOptions')
Modifier and Type | Field and Description |
---|---|
static String |
IDENTIFIER |
catalog
Constructor and Description |
---|
CompactDatabaseProcedure() |
Modifier and Type | Method and Description |
---|---|
String[] |
call(org.apache.flink.table.procedure.ProcedureContext procedureContext,
String includingDatabases,
String mode,
String includingTables,
String excludingTables,
String tableOptions,
String partitionIdleTime) |
String |
identifier()
Returns a unique identifier among same factory interfaces.
|
execute, execute, execute, notnull, nullable, optionalConfigMap, table, withCatalog
public static final String IDENTIFIER
public String[] call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String includingDatabases, String mode, String includingTables, String excludingTables, String tableOptions, String partitionIdleTime) throws Exception
Exception
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
).
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.