public class RefreshObjectTableProcedure extends ProcedureBase
CALL sys.refresh_object_table('tableId')
catalog
Constructor and Description |
---|
RefreshObjectTableProcedure() |
Modifier and Type | Method and Description |
---|---|
org.apache.flink.types.Row[] |
call(org.apache.flink.table.procedure.ProcedureContext procedureContext,
String tableId) |
String |
identifier()
Returns a unique identifier among same factory interfaces.
|
execute, execute, execute, notnull, nullable, optionalConfigMap, table, withCatalog
public org.apache.flink.types.Row[] call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String tableId) throws Catalog.TableNotExistException
Catalog.TableNotExistException
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.