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

比眉伴天荒 2023-10-02 18:26 23阅读 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 条评论，23人围观）

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

相关阅读

相关 Flink 1.9 Table API问题读取kafka

Flink 1.9 API问题 [Flink: Could not find a suitable table factory for 'org.apache.fl...

小咪咪/ 2024年04月18日 10:45/ 0 赞/ 65 阅读

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

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

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

相关 Flink Table Api读取kafka数据

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

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

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

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

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

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

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

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

相关 Flink之Table API与SQL（二）

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

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

相关 Flink之Table API与SQL（一）

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

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

相关大数据之Flink Table API 与 SQL

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

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

相关 Flink Table API 和 SQL之概述

Flink针对标准的流处理和批处理提供了两种相关的API，Table API和sql。TableAPI允许用户以一种很直观的方式进行select 、filter和join操作。

矫情吗；*/ 2022年04月14日 02:50/ 0 赞/ 228 阅读

相关 Flink table API 操作

Table API是用于流和批处理的统一关系API。表API查询可以在批量或流式输入上运行而无需修改。Table API是SQL语言的超级集合，专门用于Apache Flink

我会带着你远行/ 2021年11月22日 03:02/ 0 赞/ 338 阅读