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

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

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

相关阅读

相关 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 赞/ 53 阅读

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

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

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

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

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

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

相关 Flink之Table API与SQL（二）

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

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

相关 Flink之Table API与SQL（一）

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

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

相关大数据之Flink Table API 与 SQL

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

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

相关 Flink 原理与实现：Table & SQL API

1. 前言 Flink 已经拥有了强大的 DataStream/DataSet API，可以基本满足流计算和批计算中的所有需求。为什么还需要 Table & SQL AP

╰+攻爆jí腚メ/ 2022年04月23日 06:34/ 0 赞/ 285 阅读

相关 Flink Table API 和 SQL之概述

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

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

相关【Flink】Table API和SQL API

Flink具有两个关系API - 表API和SQL - 用于统一流和批处理。Table API是Scala和Java的语言集成查询API，允许以非常直观的方式组合来自关系

妖狐艹你老母/ 2022年02月01日 05:07/ 0 赞/ 210 阅读

相关 Flink table API 操作

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

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