本产品(实时计算 Flink版/2022-07-18)的OpenAPI采用ROA签名风格,签名细节参见签名机制说明我们已经为开发者封装了常见编程语言的SDK,开发者可通过下载SDK直接调用本产品OpenAPI而无需关心技术细节。如果现有SDK不能满足使用需求,可通过签名机制进行自签名对接。由于自签名细节非常复杂,需花费 5个工作日左右。因此建议加入我们的服务钉钉群(78410016550),在专家指导下进行签名对接。
在使用API前,您需要准备好身份账号及访问密钥(AccessKey),才能有效通过客户端工具(SDK、CLI等)访问API。细节请参见获取AccessKey

作业草稿文件夹

API标题API概述
CreateFolder创建文件夹创建文件夹。
UpdateFolder更新文件夹调用本API可完成对文件夹信息的更新。
DeleteFolder删除文件夹删除空文件夹,如果该文件夹下存在其他文件或文件夹则无法删除。
GetFolder获取文件夹信息获取文件夹的具体信息。

作业草稿

API标题API概述
CreateDeploymentDraft创建作业草稿创建SQL作业的作业草稿。
UpdateDeploymentDraft更新作业草稿更新SQL作业草稿。
DeleteDeploymentDraft删除作业草稿删除SQL作业草稿,如该草稿存在已经上线或运行中的部署作业,则无法删除。
GetDeploymentDraft获取作业草稿详情获取sql作业草稿详情。
ListDeploymentDrafts查看作业草稿列表获取SQL作业草稿的列表信息。
GetDeploymentDraftLock获取作业草稿编辑锁当您调用API编辑作业草稿时,为避免页面操作和API操作互相影响,您需要先获取编辑锁。
DeployDeploymentDraftAsync部署作业草稿SQL作业草稿部署上线。
GetDeployDeploymentDraftResult获取作业草稿部署结果根据作业草稿部署异步工单的ID信息,查看部署的结果。

自定义函数

API标题API概述
CreateUdfArtifact创建自定义函数文件通过对您上传的Jar/Python包的解析,解析您Jar/Python包中全部的UDF方法并为你创建自定义函数文件。
UpdateUdfArtifact更新自定义函数文件对已创建的自定义函数文件进行更新。
GetUdfArtifacts获取自定义函数资源详情获取您上传并创建的包含UDF的Jar或者Python文件的详情信息。
DeleteUdfArtifact删除自定义函数资源删除已经创建的自定义函数资源,删除前需要您先删除该资源下注册的自定义函数。
DeleteUdfFunction删除自定义函数删除已注册的自定义函数。
RegisterUdfFunction注册自定义函数通过本API可以选择已创建的自定义函数文件中解析出的自定义函数,选择其中的部分或全部函数进行注册,注册后可在SQL中使用。

自定义连接器

API标题API概述
ListCustomConnectors获取自定义连接器列表获取已注册的自定义连接器的列表信息。
RegisterCustomConnector注册自定义连接器在项目空间下注册自定义连接器,注册的自定义连接器可以在SQL中使用。
DeleteCustomConnector删除自定义连接器删除已经注册的自定义连接器。

元数据

API标题API概述
GetDatabases获取Database信息获取指定Catalog下DataBase的信息或列出所有DataBase的信息。
GetTables获取表信息获取指定catalog的database下某张表的具体详情或者database下所有表的信息。
GetCatalogs获取Catalog信息获取指定或全部catalog详情。
ExecuteSqlStatement执行元数据SQL语句您可以通过本API完成元数据相关SQL的运行,仅支持DDL和DML,不支持DQL。

快照

API标题API概述
CreateSavepoint创建快照创建快照。
GetSavepoint获取快照和系统检查点获取快照和系统检查点的详细信息。
DeleteSavepoint删除快照删除快照。
ListSavepoints获取作业快照及系统检查点列表获取作业快照及最近系统检查点列表。

已部署作业

API标题API概述
CreateDeployment创建已部署作业创建一个已部署作业。
UpdateDeployment更新已部署作业更新已部署作业的信息。
GetDeployment获取已部署作业获取已部署作业的详细信息。
ListDeployments获取已部署作业列表获取所有已部署作业的信息。
DeleteDeployment删除已部署作业根据已部署作业ID删除已部署作业。
GetEvents获取运行事件获取运行事件。

作业实例

API标题API概述
GetJob获取作业实例获取作业实例的详细信息。
ListJobs获取作业实例列表获取到某个已部署作业下所有作业实例的信息。
StartJobWithParams启动作业实例启动一个作业实例。
StopJob停止作业实例停止一个作业实例。
DeleteJob删除作业实例删除一个作业下非运行状态的作业实例信息。
HotUpdateJob动态更新作业对正在运行的作业进行参数或资源的动态更新。
GetHotUpdateJobResult获取作业动态更新结果对作业进行动态更新时,可通过本API获取作业动态更新的结果。
GetLatestJobStartLog获取最新作业实例的启动日志获取作业实例最新的启动日志。
StartJob启动作业实例(废弃)创建并启动一个作业实例。

定时计划

API标题API概述
CreateScheduledPlan创建定时计划创建定时计划。
UpdateScheduledPlan更新定时计划更新定时计划。
DeleteScheduledPlan删除定时计划删除定时计划。
ApplyScheduledPlan应用定时计划执行定时计划。
StopApplyScheduledPlan停止应用定时计划停止应用定时计划。
GetAppliedScheduledPlan获取应用的定时计划获取应用的执行计划。
ListScheduledPlanExecutedHistory获取定时计划执行历史获取定时计划执行历史。

Session集群

API标题API概述
CreateSessionCluster创建Session集群创建Session集群。
UpdateSessionCluster更新Session集群更新Session集群。
DeleteSessionCluster删除Session集群删除Session集群。
GetSessionCluster获取Session集群获取Session集群。
ListSessionClusters获取Session集群列表获取Session集群的列表信息。
StartSessionCluster启动Session集群启动Session集群。
StopSessionCluster停止Session集群停止Session集群。

作业部署目标

API标题API概述
CreateDeploymentTarget创建部署目标创建部署目标。
UpdateDeploymentTarget更新部署目标更新部署目标。
DeleteDeploymentTarget删除部署目标删除部署目标。
ListDeploymentTargets获取部署目标列表获取作业可部署目标的列表,部署目标是session集群或者perjob集群。

成员管理

API标题API概述
CreateMember新增成员授权将一个用户添加到对应项目空间下并授予对应权限。
UpdateMember更新用户授权信息更新特定项目空间下某个或某些用户的权限。
DeleteMember删除用户权限删除指定的用户权限信息。
GetMember查看成员授权信息查看用户授权详情。
ListMembers查看项目下成员授权列表查看特定项目下用户UID和授权的对应关系。

变量

API标题API概述
CreateVariable创建变量创建变量。
DeleteVariable删除变量删除变量。
ListVariables获取变量列表获取变量列表。

其他

API标题API概述
ListEngineVersionMetadata获取引擎版本列表获取系统支持的引擎版本列表。
ValidateSqlStatement验证sql语句校验sql作业代码。
GenerateResourcePlanWithFlinkConfAsync异步生成细粒度资源提交异步生成resource plan工单,返回一个异步工单ID用于查询工单结果。
GetGenerateResourcePlanResult获取异步生成细粒度资源结果根据异步工单ID获取异步生成细粒度资源结果。
FlinkApiProxyFlink Rest API代理您可以使用flink rest api的方式来调用本接口,获取session集群或者运行作业的相关信息。注意本接口仅支持您获取相关信息,无法对session集群和作业进行操作或管理。
GetLineageInfo获取血缘信息通过本API可以获取作业和数据的血缘信息。