public abstract class ProcedureBase extends Object implements org.apache.flink.table.procedures.Procedure, Factory
Procedure
.Constructor and Description |
---|
ProcedureBase() |
Modifier and Type | Method and Description |
---|---|
protected String[] |
execute(org.apache.flink.table.procedure.ProcedureContext procedureContext,
ActionBase action,
String defaultJobName) |
protected String[] |
execute(org.apache.flink.table.procedure.ProcedureContext procedureContext,
org.apache.flink.core.execution.JobClient jobClient) |
protected String[] |
execute(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env,
String defaultJobName) |
protected String |
notnull(String arg) |
protected String |
nullable(String arg) |
protected Map<String,String> |
optionalConfigMap(String configStr) |
protected Table |
table(String tableId) |
ProcedureBase |
withCatalog(Catalog catalog) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
identifier
protected Catalog catalog
public ProcedureBase withCatalog(Catalog catalog)
protected Table table(String tableId) throws Catalog.TableNotExistException
Catalog.TableNotExistException
protected String[] execute(org.apache.flink.table.procedure.ProcedureContext procedureContext, ActionBase action, String defaultJobName) throws Exception
Exception
protected String[] execute(org.apache.flink.table.procedure.ProcedureContext procedureContext, org.apache.flink.core.execution.JobClient jobClient)
protected String[] execute(org.apache.flink.streaming.api.environment.StreamExecutionEnvironment env, String defaultJobName) throws Exception
Exception
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.