Blink 漫谈系列 - HelloWorld

本文涉及的产品
实时计算 Flink 版,5000CU*H 3个月
简介:

眼见为实

目前我们概要了解了Blink的强大与宏伟目标(世界一流),但我们相信任何事物的发展都要符合自然规律,一颗小树要长成参天大树要上百年,我们的马老师今天能为亿万人民创造工作,经历近20年,Blink也一样其宏伟目标的实现,需要时间的沉淀,智慧的积累。 用户在给予Blink成长时间的同时也应该体会到Blink亲民的点滴,本篇以HelloWorld为例,带新用户走进Blink。
 

IDE 写SQL

本篇要写一个最简单的Blink SQL,核心功能是一个同步数据的功能,就是将数据表Source的数据插入到结果表Sink。
 
  • 创建
  • 编写SQL
    上一步我们在book目录下面,创建了一job名为book_helloworld,作业类型为BLINK-SQL,运行在blink-1.6.0版本。打开Job开始编写sql,如下:
    --Blink SQL
    --********************************************************************--
    --Author: 
    --CreateTime: 2018-04-06 08:51:33
    --Comment: 请输入业务注释信息
    --********************************************************************--
    
    CREATE TABLE helloWorld_source(
        col_boolean  BOOLEAN,
    	col_tinyint TINYINT,
    	col_smallint SMALLINT,
    	col_int INT,
    	col_bigint BIGINT,
    	col_float FLOAT,
    	col_double DOUBLE,
    	col_decimal DECIMAL,
    	col_date DATE,
    	col_time TIME,
    	col_timestamp TIMESTAMP,
    	col_varchar VARCHAR,
    	col_varbinary VARBINARY
      )WITH(
       type='random'
     ) ;
    
    CREATE TABLE helloWorld_sink(
        col_boolean  BOOLEAN,
    	col_tinyint TINYINT,
    	col_smallint SMALLINT,
    	col_int INT,
    	col_bigint BIGINT,
    	col_float FLOAT,
    	col_double DOUBLE,
    	col_decimal DECIMAL,
    	col_date DATE,
    	col_time TIME,
    	col_timestamp TIMESTAMP,
    	col_varchar VARCHAR,
    	col_varbinary VARBINARY
       )WITH(
        type = 'print'
     ) ;
    
    INSERT INTO helloWorld_sink 
        SELECT 
            col_boolean  ,
    	    col_tinyint ,
    	    col_smallint ,
    	    col_int ,
    	    col_bigint ,
    	    col_float ,
    	    col_double ,
    	    col_decimal ,
    	    col_date ,
    	    col_time ,
    	    col_timestamp ,
    	    col_varchar ,
    	    col_varbinary 
        FROM helloWorld_source;
    
完成上面的书写,我们可以点击【上线】进行资源配置,如下图:
 
  • 启动job
    经过上面步骤,我们可以点击 【运维】启动job了,如下步骤:
 
container log可以看到我们上面的print输出
  • We did it.
虽然上面截图花费了一些时间,但是若您按照步骤操作,其实3分钟应该能体验上面全部流程,至此Helloword的Blink sql体验结束.

小结

本篇一个简单HelloWorld将新用户带入了Blink的使用中,虽然是最简单的示例,但体现了Blink IDE中60%的操作,并且我们的sql定义中使用了Blink支持的除了Any之外的所有数据类型。同时用户初步看到了blink sql的基础结构 source -> query -> sink. 也就是我们围绕这ANSI-SQL的DDL和DML就可以完成我们的业务job了。
相关实践学习
基于Hologres轻松玩转一站式实时仓库
本场景介绍如何利用阿里云MaxCompute、实时计算Flink和交互式分析服务Hologres开发离线、实时数据融合分析的数据大屏应用。
Linux入门到精通
本套课程是从入门开始的Linux学习课程,适合初学者阅读。由浅入深案例丰富,通俗易懂。主要涉及基础的系统操作以及工作中常用的各种服务软件的应用、部署和优化。即使是零基础的学员,只要能够坚持把所有章节都学完,也一定会受益匪浅。
目录
相关文章
|
SQL 固态存储 Java
Apache Doris 原生C++ UDF之Coding(2)
Apache Doris 原生C++ UDF之Coding(2)
89 0
|
2月前
|
存储 Java 数据处理
Flink-01 介绍Flink Java 3分钟上手 HelloWorld 和 Stream ExecutionEnvironment DataSet FlatMapFunction
Flink-01 介绍Flink Java 3分钟上手 HelloWorld 和 Stream ExecutionEnvironment DataSet FlatMapFunction
43 1
|
4月前
|
Shell 开发工具 Docker
GitlabCI学习笔记之二:GitLabRunner pipeline语法之job script stages
GitlabCI学习笔记之二:GitLabRunner pipeline语法之job script stages
|
7月前
|
XML 自然语言处理 C++
【Qt 学习笔记】使用两种方式实现helloworld
【Qt 学习笔记】使用两种方式实现helloworld
71 1
|
SQL 关系型数据库 MySQL
怎么使用 Go 语言操作 Apache Doris
怎么使用 Go 语言操作 Apache Doris
1012 0
|
SQL Java Apache
Apache Doris 原生C++ UDF之Coding(2)2
Apache Doris 原生C++ UDF之Coding(2)2
146 0
|
固态存储 Apache C++
Apache Doris 原生C++ UDF之Coding(2)1
Apache Doris 原生C++ UDF之Coding(2)1
196 0
|
编解码 Java 程序员
Android入门教程 (二) 第一个App HelloWorld
Android入门教程 (二) 第一个App HelloWorld
879 0
|
BI API 流计算
Flink window 用法介绍(3)
Flink window 用法介绍(3)
158 0
Flink window 用法介绍(3)
|
消息中间件 传感器 NoSQL
Flink window 用法介绍(1)
Flink window 用法介绍(1)
171 0
Flink window 用法介绍(1)