如何解决如何以批处理模式显示 TableEnvironment 的表格内容
我使用的是 Flink 1.12.0,并使用以下代码处理批处理数据。
我想显示表格的内容。当我调用 print
时,它抱怨无法将表转换为数据集,但我不想使用 BatchTableEnviroment,这是一种旧的规划器 API。
test("batch test") {
val settings = EnvironmentSettings.newInstance().inBatchMode().useBlinkPlanner().build()
val tenv = TableEnvironment.create(settings)
val ddl =
"""
create table sourceTable(
key STRING,`date` STRING,price DOUBLE
) with (
'connector' = 'filesystem','path' = 'D:/projects/openprojects3/learn.flink.ioc/data/stock.csv','format' = 'csv'
)
""".stripMargin(' ')
tenv.executeSql(ddl)
val table = tenv.sqlQuery(
"""
select * from sourceTable
""".stripMargin(' '))
table.print()
}
解决方法
据我所知,处理时间时态表连接要求查找表由 LookupTableSource
支持。到目前为止,在 Flink 代码库本身中,只有 Hive、HBase 和 JDBC 连接器实现了这个接口。如果你想快速尝试一下,你也可以使用 [1],它也实现了上述接口。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。