< 文档首页
实时计算Flink版
文档最新动态
产品简介
什么是阿里云实时计算Flink版
产品形态
应用场景
Flink全托管
产品公告
新功能发布记录
2021-01-20版本
2021-01-11版本
2020-12-03版本
2020-10-27版本
2020-07-23版本
产品定价
产品概览
概述
管理控制台介绍
支持的上下游存储
准备工作
角色授权
设置白名单
账号授权
开通流程
项目管理
配置Session集群
Flink SQL参考
概述
关键字
创建数据视图
DDL语句
创建数据源表
日志服务SLS源表
Datagen源表
消息队列Kafka源表
数据总线DataHub源表
全量MaxCompute源表
增量MaxCompute源表
消息队列RocketMQ版源表
交互式分析Hologres源表
全量Elasticsearch源表
Postgres的CDC源表
MySQL的CDC源表
创建数据结果表
Blackhole结果表
日志服务SLS结果表
消息队列Kafka结果表
数据总线DataHub结果表
表格存储Tablestore结果表
MaxCompute结果表
消息队列RocketMQ版结果表
云数据库HBase版结果表
云数据库Redis版结果表
交互式分析Hologres结果表
云数据库MongoDB版结果表
Elasticsearch结果表
Phoenix5结果表
云数据库RDS MySQL结果表
云原生数据仓库AnalyticDB MySQL版3.0结果表
print结果表
创建数据维表
云数据库HBase版维表
表格存储Tablestore维表
MaxCompute维表
云数据库Redis版维表
Elasticsearch维表
交互式分析Hologres维表
云数据库RDS MySQL维表
云原生数据仓库AnalyticDB MySQL版3.0维表
DML语句
INSERT INTO语句
QUERY语句
自定义函数(UDX)
概述
自定义标量函数(UDF)
自定义聚合函数(UDAF)
自定义表值函数(UDTF)
窗口函数
概述
滚动窗口
滑动窗口
会话窗口
OVER窗口
内置函数
Flink SQL开发指南
概述
作业开发
作业提交
作业暂停与停止
作业调试
管理自定义函数(UDF)
配置Hive Metastore
管理自定义Connectors
Flink Datastream开发指南
概述
作业开发
作业提交
作业暂停与停止
运维管理
作业运维
配置监控告警(在ARMS控制台中配置)
配置监控告警(在Flink全托管开发控制台配置)
配置作业日志
查看作业日志
配置自动调优
集群配置管理
工作空间资源变配
组件管理
修改虚拟交换机
安全与监控
操作审计日志
SDK参考
OpenAPI SDK
常见问题
视频专区
Flink全托管开通流程
最佳实践
读取DataHub数据写入阿里云HBase
相关协议
Flink全托管服务等级协议(SLA)
Flink半托管/ACK
新功能发布记录
2.1.5版本
2.1.3版本
产品定价
产品概览
概述
支持的上下游存储
管理控制台介绍
开发控制台组件介绍
准备工作
角色授权
RAM账号授权
开通流程
作业开发
开发
提交
运维管理
作业运维
开源自建监控组件(ACK)
配置及查看作业日志
链路监控
常见问题
相关协议
Flink半托管/ACK服务等级协议(SLA)
Blink独享/共享集群(原产品线)
产品公告
新功能发布记录
Blink-3.7.9
Blink-3.7.7
Blink-3.6.8
Blink-3.6.5
Blink-3.6.2
Blink-3.6.0
Blink-3.5.0-hotfix
Blink-3.4.3
Blink-3.4.4
Blink-3.3.0
Blink-3.2.3
Blink-3.2.1
Blink-3.2.1新功能发布记录
Blink 3.2与Flink 1.5.1版本API兼容性报告
Blink 3.0与Blink 2.0版本SQL不兼容项汇总
产品概览
概述
发展历程
业务流程
管理控制台介绍
支持的上下游存储
产品安全
使用限制
产品定价
计量项
计费方式
规格选择
续费指导
手动续费
自动续费
变配指导
释放集群
准备工作
主子账号授权
开通服务和创建项目
角色授权
共享模式角色授权
独享模式角色授权
快速入门
概述
搭建上下游存储
搭建数据源表存储
搭建数据维表存储
搭建数据结果表存储
数据开发
作业上线
生产运维
Flink SQL参考
概述
关键字
基本概念
时区
时间属性
Watermark
计算列
数据类型
类型转换
数学和逻辑运算
创建数据视图
DDL语句
概述
创建数据源表
创建数据结果表
创建数据维表
DML语句
INSERT INTO语句
EMIT语句
QUERY语句
SELECT语句
WHERE语句
HAVING语句
GROUP BY语句
JOIN语句
维表JOIN语句
IntervalJoin语句
UNION ALL语句
TopN语句
GROUPING SETS语句
复杂事件处理(CEP)语句
去重语句
窗口函数
概述
滚动窗口
滑动窗口
会话窗口
OVER窗口
内置函数
字符串函数
数学函数
日期函数
逻辑函数
条件函数
表值函数
类型转换函数
聚合函数
其他函数
自定义函数(UDX)
概述
自定义标量函数(UDF)
自定义聚合函数(UDAF)
自定义表值函数(UDTF)
使用IntelliJ IDEA开发自定义函数
Flink SQL开发指南
概述
数据存储
数据存储概述
注册数据存储
VPC访问授权
数据存储白名单配置
作业开发
开发
上线
启动
暂停
停止
作业调试
本地调试
线上调试
作业运维
运行信息
数据曲线
Timeline
Failover
Checkpoints
JobManager
TaskExecutor
血缘关系
属性参数
作业诊断
作业调优
概述
高性能Flink SQL优化技巧
AutoConf自动配置调优
AutoScale自动配置调优
手动配置调优
典型的反压场景及优化思路
SQL Tuning Advisor
Partitioned All Cache调优
MiniBatch/MicroBatch调优
Cache优化
Async优化
APPROX_COUNT_DISTINCT优化
Local-Global优化
ROW_NUMBER OVER WINDOW去重
Partial-Final优化
监控报警
自定义日志级别和下载路径
管理独享集群Blink版本
Flink Datastream开发指南
概述
数据存储白名单配置
自定义参数
监控报警
作业开发
作业提交
Datastream示例
读取DataHub数据示例
读取Kafka数据示例
读取DataHub数据写入阿里云HBase示例
读取日志服务SLS示例
OpenAPI
简介
OpenAPI概览
RAM资源授权
调用方式
签名机制
请求结构
返回结果
公共参数
实例
BatchGetInstanceRunSummary
GetInstance
GetInstanceResource
GetInstanceCheckpoint
GetInstanceConfig
GetInstanceDetail
GetInstanceExceptions
GetInstanceFinalState
GetInstanceMetric
GetInstanceRunSummary
ListInstance
ModifyInstanceState
GetInstanceHistoryAutoScalePlanContent
GetInstanceHistoryAutoScalePlanList
文件夹
CreateFolder
DeleteFolder
GetFolder
ListChildFolder
MVFolder
作业
GetRawPlanJson
CheckRawPlanJson
CommitJob
CreateJob
DeleteJob
GetJob
ListJob
OfflineJob
StartJob
UpdateJob
ValidateJob
CalcPlanJsonResource
UpdateAutoScaleConfig
GetJobLatestAutoScalePlan
Package
CreatePackage
DeletePackage
GetPackage
GetRefPackageJob
ListPackage
UpdatePackage
Queue
CreateQueue
DeleteQueue
BindQueue
UnbindQueue
GetClusterQueueInfo
ListProjectBindQueue
ListProjectBindQueueResource
UpdateQueue
Cluster
CreateCluster
CreateCellClusterOrder
DestroyCluster
ExpandCluster
ShrinkCluster
ListCluster
GetClusterDetails
GetClusterEngineVersions
GetClusterResource
ModifyMasterSpec
GetClusterMetrics
Project
CreateProject
DeleteProject
GetProject
ListProject
OpenAPI DEMO
常见问题
用户支持渠道
计量计费
基本概念
如何使用
分场景排错指引
上下游存储
SQL常见问题
语法检查报错
调试报错
上线报错
启动报错
运行Failover
视频专区
实时计算购买流程
实时计算产品详解
新手案例
案例介绍
上下游数据表创建
数据调试
上线作业
最佳实践
电商行业最佳实践
电商场景实战之实时PV和UV曲线
电商场景实战之订单与销量统计
电商场景实战之实时态势感知和订单地理分布
电商场景实战之多类目成交总额管理
电商场景实战之营销红包
电商场景实战之最新交易记录获取
IoT行业最佳实践
IoT解决方案之多维度传感器数据分析
视频直播行业最佳实践
视频直播解决方案之视频核心指标监控
视频直播解决方案之直播数字化运营
相关协议
实时计算服务等级协议(SLA)
全部产品
弹性计算
云服务器 ECS
轻量应用服务器
GPU云服务器
FPGA云服务器
专有宿主机
弹性云桌面
弹性高性能计算E-HPC
批量计算
弹性伸缩
资源编排
运维编排服务
函数计算
Serverless应用引擎
Serverless工作流
弹性加速计算实例EAIS
存储
对象存储 OSS
表格存储 Tablestore
文件存储 NAS
文件存储 CPFS
文件存储 HDFS
数据库文件存储
内容协作平台
相册与网盘服务
日志服务
智能媒体管理
离线迁移服务(闪电立方)
混合云备份服务
混合云容灾服务
云存储网关
混合云存储阵列
在线迁移服务
智能云相册
数据库
PolarDB MySQL 云原生数据库
PolarDB-O 云原生数据库
PolarDB PostgreSQL 云原生数据库
PolarDB-X 云原生分布式数据库
云数据库 RDS
云数据库 OceanBase
云数据库专属集群 MyBase
云原生多模数据库 Lindorm
云数据库 Redis
云数据库 MongoDB
云数据库 HBase
云数据库 Cassandra
时序数据库 TSDB
图数据库 GDB
云数据库 Memcache
可信账本数据库 LedgerDB
云原生数仓 AnalyticDB MySQL
云原生数仓 AnalyticDB PostgreSQL
云数据库 ClickHouse
云原生数据湖分析 DLA
数据传输服务 DTS
数据管理 DMS
数据库备份 DBS
数据库自治服务 DAS
数据库网关 DG
数据库专家服务
数据库和应用迁移服务 ADAM
HybridDB for MySQL
安全
安全公告和技术
DDoS防护
Web 应用防火墙
SSL证书
云安全中心
云防火墙
堡垒机
漏洞扫描
操作审计
终端访问控制系统
访问控制
应用身份服务
数据库审计
加密服务
敏感数据保护
内容安全
密钥管理服务
风险识别
实人认证
爬虫风险管理
游戏盾
安全管家
先知(安全众测)
安骑士
人机验证
金融级实人认证
智能核身(增强版)
云安全访问服务
威胁情报
特权访问服务
大数据
MaxCompute
E-MapReduce
阿里云Elasticsearch
数据湖构建
实时计算Flink版
交互式分析Hologres
Databricks数据洞察
开放搜索
图计算服务
DataWorks
智能数据构建与管理 Dataphin
Quick BI
DataV数据可视化
智能推荐
智能用户增长
数据资源平台
DataHub
公众趋势分析
人工智能
机器学习PAI
卫星及无人机遥感影像分析产品
图像搜索
视觉计算服务
智能视觉生产
城市视觉智能引擎
多媒体AI
智能语音交互
印刷文字识别
自然语言处理
交通云控平台
工业大脑开放平台
机器翻译
人工智能众包
全息空间
智能语义理解
视频内容检索
语言协同平台
三维空间重建
阿里云视觉智能开放平台
网络与CDN
网络介绍
专有网络 VPC
云解析 PrivateZone
负载均衡
NAT 网关
弹性公网 IP
IPv6转换服务
共享带宽
共享流量包
云企业网
全球加速
智能接入网关
高速通道
CDN
全站加速
SCDN
PCDN
边缘节点服务ENS
IPv6网关
VPN网关
私网连接 PrivateLink
Anycast EIP
云网管
视频服务
视频直播
视频点播
音视频通信
云视频会议
媒体处理
视频监控
智能视觉
智能媒体生产
容器与中间件
容器服务Kubernetes版
服务网格 ASM
弹性容器实例
容器镜像服务 ACR
企业级分布式应用服务 EDAS
微服务引擎MSE
应用配置管理 ACM
全局事务服务 GTS
云服务总线 CSB
消息队列RocketMQ版
事件总线EventBridge
消息队列Kafka版
消息队列RabbitMQ版
微消息队列 MQTT 版
消息服务MNS
分布式任务调度 SchedulerX
开发与运维
应用实时监控服务ARMS
Prometheus 监控
云监控
应用高可用服务 AHAS
智能顾问
Node.js 性能平台
链路追踪Tracing Analysis
Web应用托管服务
性能测试 PTS
移动测试
应用发现服务
服务器迁移中心
移动研发平台 EMAS
移动DevOps
移动热修复
崩溃分析
性能分析
远程日志
移动推送
移动数据分析
移动用户反馈
HTTPDNS
OpenAPI Explorer
云命令行
逻辑编排
Alibaba Cloud Toolkit
云效
云效2020
资源管理
小程序云
全局流量管理
配置审计
管理控制台
IT治理样板间
云架构设计工具
配额中心
全域用户行为洞察分析平台
API与工具
阿里云CLI
集成开发最佳实践
CodePipeline
阿里云交易和账单管理API
Terraform
Ansible
Java SDK
Python SDK
Go SDK
.NET SDK
PHP SDK
Node.js SDK
Pulumi
云开发平台
工单系统API
物联网
阿里云物联网平台
设备接入Link SDK
IoT物联网操作系统
IoT设备身份认证
物联网应用开发
物联网数据分析
物联网边缘计算
视频边缘智能服务
物联网络管理平台
物联网无线连接服务
IoT安全运营中心
IoT可信执行环境
IoT固件安全检测
IoT安全解决方案
IoT可信服务管理
生活物联网平台
AIoT开放平台
物联网应用托管服务
物联网应用服务
智联车管理云平台
物联网行业方案
工业互联网平台
物联网市场
阿里云IoT技术认证
数字社区平台
线下广告投放平台
AIoT数字园区引擎
专有云
企业版
敏捷版
敏捷大数据版
一体机
移动研发平台EMAS-专有云
Native DevOps
跨平台 DevOps
移动API网关
通道服务
远程配置
移动监控
移动测试
移动热修复
移动数据分析
移动推送
企业应用与服务
Teambition
云投屏
机器人流程自动化RPA
宜搭
云行情
工业视觉智能
货架商品识别与管理
政务钉钉
地址标准化
IP地理位置库
云游戏平台
备案
云 AP
API 网关
邮件推送
云价签
专属钉钉解决方案
区块链服务 BaaS
可信计算服务
分布式数字身份
跨链数据连接服务
短信服务
语音服务
智能联络中心
号码隐私保护
号码认证服务
号码百科
云通信网络加速
云呼叫中心
云小蜜
智能外呼机器人
智能语音导航
智能对话分析
云客服
智能双录质检
Linkedmall
鹿班
智能数据助理
云市场
数字金融
移动开发平台 mPaaS
金融分布式架构 SOFAStack
SOFAStack 微服务
SOFAStack API 统一网关
金融云
域名与网站
域名
云虚拟主机
云解析 DNS
阿里云公共DNS
企业邮箱
弹性 Web 托管
ICP许可证
EDI许可证
食品经营许可证
云·速成美站
云·企业官网
资质管家服务
网络文化经营许可证(文网文)
CDN经营许可证
IDC经营许可证
SP经营许可证
ISP经营许可证
高新技术企业认定
工商财税与知识产权
阿里云商标服务
工商注册服务
软件著作权登记
图片服务
代理记账
智能logo设计
智能财税
解决方案
SAP 解决方案
通用解决方案
阿里政务云
MindSphere on Alibaba Cloud
阿里云VMware服务
会员服务
财务
用户中心
账号管理
费用中心
会员积分
活动
云大使推荐返现
飞天会员
更多
支持与服务
信任中心
阿里云App
阿里云图标
法律条款
阿里云规则
Red Hat云接入和Windows许可证
阿里云认证
实时计算Flink版
>
Blink独享/共享集群(原产品线)
>
视频专区
>
新手案例
>
上下游数据表创建
上下游数据表创建
更新时间:2019-06-18 09:40
我的收藏
本页目录
上下游
上一篇:
下一篇:
以上内容是否对您有帮助?
在文档使用中是否遇到以下问题
内容错误
更新不及时
链接错误
缺少代码/图片示例
太简单/步骤待完善
其他
内容错误
更新不及时
链接错误
缺少代码/图片示例
太简单/步骤待完善
其他
更多建议
提交建议
匿名提交
感谢您的打分,是否有意见建议想告诉我们?
提交建议
感谢您的反馈,反馈我们已经收到
文档反馈
鼠标选中内容,快速选择问题
选中存在疑惑的文档内容,即可生成截图进行反馈,我们会跟进处理。
好的,知道了
文档反馈
在文档使用中是否遇到以下问题
更多建议
匿名提交