全部面试刷题微服务数据库消息队列搜索引擎大数据运维 go语言人工智能

Flink Table API&SQL中创建表的方式有哪些？

提问者：帅平问题分类：面试刷题

Flink

发布于：2年前 (2023-08-18) IP属地：四川省

2 个回答

小xの碎碎念

第二种从数据源中创建表，例如:

final TableDescriptor sourceDescriptor = TableDescriptor.forConnector("datagen")
    .schema(Schema.newBuilder()
    .column("f0", DataTypes.STRING())
    .build())
    .option(DataGenConnectorOptions.ROWS_PER_SECOND, 100L)
    .build();
tableEnv.createTable("test", sourceDescriptor);
tableEnv.createTemporaryTable("test1", sourceDescriptor);
tableEnv.executeSql("CREATE [TEMPORARY] TABLE MyTable (...) WITH (...)");

发布于：2年前 (2023-08-18) IP属地：四川省

最终是我淘汰出局

第一种从已有的表中创建表，例如：

TableEnvironment tableEnv = ...; 
Table test1= tableEnv.from("test1").select(...);
tableEnv.createTemporaryView("test2", test1);

发布于：2年前 (2023-08-18) IP属地：四川省

我来回答