Flink tableapi从文件系统创建表

//注册表
oldTableEnv
.connect(new FileSystem().path(“src/main/resources/sensor.txt”))
.withFormat(new OldCsv())
.withSchema(new Schema()
.field(“id”, DataTypes.STRING())
.field(“ts”, DataTypes.BIGINT())
.field(“temperature”, DataTypes.DOUBLE())
)
.createTemporaryTable(“inputtable”)
//从表中创建table
val table = oldTableEnv.from(“inputtable”)