热门搜索:
您现在的位置是：首页 > 文章详情

数据结果表概述

日期：2018-11-13点击：529

实时计算 Flink使用CREATE TABLE作为输出结果数据的格式定义，同时定义数据如何写入到目的数据存储。实时计算有Append类型和Update类型。

  • Append类型：如果输出存储是日志系统或消息系统，或未定义主键的RDS，则流的输出结果都会以追加的方式写入存储中，而不会修改存储中原有的数据。

  • Update类型：如果输出存储是声明了主键（PRIMARY KEY）的数据库（例如RDS、HBase），流的输出结果会发生以下两种情况。

    • 如果根据主键查询数据在数据库中不存在，则会将该数据插入到数据库。
    • 如果根据主键查询数据在数据库中存在，则会根据主键更新数据。

语法

 
  
     
   
  1.  CREATE TABLE tableName
    2.  
   
  2.  (columnName dataType [, columnName dataType ]*)
    3.  
   
  3.  [ WITH (propertyName=propertyValue [, propertyName=propertyValue ]*) ];
    4.  
  
 
 
 
 
 示例
 
 
 
  
 
   
    
  
 
  
 
  
     
   
  1. create table rds_output(
    2.  
   
  2.  id int,
    3.  
   
  3.  len int,
    4.  
   
  4.  content VARCHAR,
    5.  
   
  5.  primary key(id)
    6.  
   
  6. ) with (
    7.  
   
  7.  type='rds',
    8.  
   
  8.  url='jdbc:mysql:XXXXXXXXXX',
    9.  
   
  9.  tableName='test4',
    10.  
   
  10.  userName='test',
    11.  
   
  11.  password='XXXXXX'
    12.  
   
  12. );
    13.  
  
 
 
 

 


 


 


 本文转自实时计算——
 数据结果表概述 


					

                    

                        原文链接：https://yq.aliyun.com/articles/669179
                    

                    

				

				

					关注公众号
					
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

					
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

					
转载内容版权归作者及来源网站所有，本站原创内容转载请注明来源。

				

				

					
				

				

					
相关文章

					
    
				
    
				
    
				
    
					
    文章评论
    
					
    
						
    共有0条评论来说两句吧...
    
						
						
						
						
					
    
				
    
			
    
			
    

    
	
    文章二维码
    
	
    
		扫描即可查看该文章
		
    
	
    

    
	
    点击排行
    
	

    

    
	
    推荐阅读
    
	

    

    
	
    最新文章