Flink Table Api 之创建表与读取外部数据

比眉伴天荒 2023-10-02 18:26 123阅读 0赞

## 前言 ##

本篇将使用Flink Table的相关API来快速编写一个程序，读取外部数据文件的数据并输出到控制台

前置准备，如下是一个提前准备好的数据文件

![watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6YCG6aOO6aOe57-U55qE5bCP5Y-U_size_7_color_FFFFFF_t_70_g_se_x_16][]

1、核心代码如下

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
    import org.apache.flink.table.api.DataTypes;
    import org.apache.flink.table.api.Table;
    import org.apache.flink.table.api.java.StreamTableEnvironment;
    import org.apache.flink.table.descriptors.Csv;
    import org.apache.flink.table.descriptors.FileSystem;
    import org.apache.flink.table.descriptors.Schema;
    import org.apache.flink.types.Row;
    
    /**
     * 第一个案例，读取外文文件数据，输出到控制台
     */
    public class Table2 {
    
        public static void main(String[] args) throws Exce

[watermark_type_d3F5LXplbmhlaQ_shadow_50_text_Q1NETiBA6YCG6aOO6aOe57-U55qE5bCP5Y-U_size_7_color_FFFFFF_t_70_g_se_x_16]: https://img-blog.csdnimg.cn/5b167e6059ff4789ababcd60d62c6dc8.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_Q1NETiBA6YCG6aOO6aOe57-U55qE5bCP5Y-U,size_7,color_FFFFFF,t_70,g_se,x_16

发表评论取消回复

表情：

评论列表（有 0 条评论，123人围观）

还没有评论，来说两句吧...

相关阅读

相关 Flink - Table API 之流与表转换

Flink - Table API 数据转换 1.DataStream或DataSet 转换为Table 目前有两种方式将DataStream或DataSet 转换

た入场券/ 2023年10月06日 18:34/ 0 赞/ 192 阅读

相关 Flink Table Api 之表函数使用

表函数（Table Functions）用户定义的表函数，也可以将0、1或多个标量值作为输入参数；与标量函数不同的是，它可以返回任意数量的行作为输出，而不是单个值

我会带着你远行/ 2023年10月02日 18:32/ 0 赞/ 27 阅读

相关 Flin Table Api 之读取dataStream数据

前言我们知道，DataStream 是flink流式数据处理中一个非常重要的数据结构，可以将DataStream转换成许多其他的数据类型，进而做灵活的数据处理，同样基于

电玩女神/ 2023年10月02日 18:27/ 0 赞/ 21 阅读

相关 Flink Table Api读取kafka数据

前言在上一篇我们通过代码演示了如何使用Flink Table Api 从外部的CSV文件中读取数据，然后输出到新的CSV文件中去；本篇将继续探讨Flink Tabl

灰太狼/ 2023年10月02日 18:26/ 0 赞/ 145 阅读

相关 Flink Table Api 之table结果查询与过滤

前言在上一篇，分享了如何快速使用Flink Table Api 读取外部文件数据，并输出到控制台，本篇将基于上一篇的操作，从table中进一步做处理，比如过滤指定字段的

╰半橙微兮°/ 2023年10月02日 18:26/ 0 赞/ 93 阅读

相关 Flink Table Api 之创建表与读取外部数据

前言本篇将使用Flink Table的相关API来快速编写一个程序，读取外部数据文件的数据并输出到控制台前置准备，如下是一个提前准备好的数据文件 ![waterm

比眉伴天荒/ 2023年10月02日 18:26/ 0 赞/ 124 阅读

相关 Flink Table Api之从文件读取数据

前言在上一篇我们从理论上讲解了下Flink Table相关的理论知识，本篇将结合实际代码，演示下如何使用Flink Table Api读取本地文件数据并输出； 1、导

系统管理员/ 2023年10月02日 18:24/ 0 赞/ 139 阅读

相关 Flink之Table API与SQL（二）

目录（1）创建表的两种方式（2）DataStream、DataSet与Table的转换（2.1）通过 DataSet

Dear 丶/ 2022年11月16日 13:41/ 0 赞/ 282 阅读

相关 Flink之Table API与SQL（一）

目录（1）Table API与SQL概念（2）Table 程序依赖（3）两种计划器（Planner）的主要区别

拼搏现实的明天。/ 2022年11月16日 01:45/ 0 赞/ 296 阅读

相关大数据之Flink Table API 与 SQL

1、Table API 与 SQL Table API 是流处理和批处理通用的关系型 API， Table API 可以基于流输入或者批输入来运行而不需要进行任何修改。

素颜马尾好姑娘i/ 2022年09月14日 15:26/ 0 赞/ 314 阅读