flinksql 表怎么讀取外部文件

這篇文章主要介紹“flinksql 表怎么讀取外部文件”，在日常操作中，相信很多人在flinksql 表怎么讀取外部文件問題上存在疑惑，小編查閱了各式資料，整理出簡(jiǎn)單好用的操作方法，希望對(duì)大家解答”flinksql 表怎么讀取外部文件”的疑惑有所幫助！接下來，請(qǐng)跟著小編一起來學(xué)習(xí)吧！

1、TableEnvironment 可以注冊(cè)目錄 Catalog， 可以基于catalog 注冊(cè)表

2、表 是由一個(gè)標(biāo)識(shí)符 來指定的， 由三部分組成：catalog、 數(shù)據(jù)庫(kù)名、對(duì)象名

3、表可以是常規(guī)的，也可以是虛擬的（視圖）

4、常規(guī)表一般可以用來描述外部數(shù)據(jù)， 比如文件、數(shù)據(jù)庫(kù)或消息隊(duì)列的數(shù)據(jù)，也可以直接從datastream轉(zhuǎn)換過來

5、視圖可以從現(xiàn)有的表中創(chuàng)建，通常是table api 或者 sql 查詢的一個(gè)結(jié)果集

代碼：

package com.jd.data;

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.bridge.java.StreamTableEnvironment;
import org.apache.flink.table.descriptors.FileSystem;
import org.apache.flink.table.descriptors.OldCsv;
import org.apache.flink.table.descriptors.Schema;
import org.apache.flink.types.Row;
import scala.Tuple3;

public class TableAipDemo03 {
    public static void main(String[] args) throws Exception {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
        env.setParallelism(1);


//        1、創(chuàng)建表執(zhí)行環(huán)節(jié)
        StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env);

        String path = "/Users/liuhaijing/Desktop/flinktestword/aaa.txt";
        tableEnv.connect(new FileSystem().path(path))
                .withFormat(new OldCsv()) // 定義格式化方法
                .withSchema(new Schema().field("a", DataTypes.STRING())  // 定義表的結(jié)構(gòu)
                        .field("b", DataTypes.STRING())
                        .field("c", DataTypes.STRING())

                )
                .inAppendMode()
                .createTemporaryTable("xxx");

        Table xxx = tableEnv.from("xxx");

        xxx.printSchema();

        tableEnv.toAppendStream(xxx,  Row.class ).print();

        env.execute("job");


    }
}

到此，關(guān)于“flinksql 表怎么讀取外部文件”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注億速云網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)砀鄬?shí)用的文章！