public class AlterViewDialectProcedure extends ProcedureBase
-- NOTE: use '' as placeholder for optional arguments
-- add dialect in the view
CALL sys.alter_view_dialect('view_identifier', 'add', 'flink', 'query')
CALL sys.alter_view_dialect(`view` => 'view_identifier', `action` => 'add', `query` => 'query')
-- update dialect in the view
CALL sys.alter_view_dialect('view_identifier', 'update', 'flink', 'query')
CALL sys.alter_view_dialect(`view` => 'view_identifier', `action` => 'update', `query` => 'query')
-- drop dialect in the view
CALL sys.alter_view_dialect('view_identifier', 'drop', 'flink')
CALL sys.alter_view_dialect(`view` => 'view_identifier', `action` => 'drop')
catalog
Constructor and Description |
---|
AlterViewDialectProcedure() |
Modifier and Type | Method and Description |
---|---|
String[] |
call(org.apache.flink.table.procedure.ProcedureContext procedureContext,
String view,
String action,
String engine,
String query) |
String |
identifier()
Returns a unique identifier among same factory interfaces.
|
execute, execute, execute, notnull, nullable, optionalConfigMap, table, withCatalog
public String[] call(org.apache.flink.table.procedure.ProcedureContext procedureContext, String view, String action, String engine, String query) throws Catalog.ViewNotExistException, Catalog.DialectAlreadyExistException, Catalog.DialectNotExistException
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–2025 The Apache Software Foundation. All rights reserved.