【发布时间】:2021-01-21 10:33:54
【问题描述】:
我是 Apache Flink 的新手,我找不到从文件系统读取 parquet 文件的方法。 我来自 Spark,一个简单的“spark.read.parquet("...")" 完成了这项工作。 有可能吗?
提前谢谢你
【问题讨论】:
标签: apache-spark apache-flink parquet
我是 Apache Flink 的新手,我找不到从文件系统读取 parquet 文件的方法。 我来自 Spark,一个简单的“spark.read.parquet("...")" 完成了这项工作。 有可能吗?
提前谢谢你
【问题讨论】:
标签: apache-spark apache-flink parquet
实际上,这取决于您阅读镶木地板的方式。 如果您尝试简单地读取 parquet 文件并想利用 DataStream 连接器,this stackoverflow question 可以作为入口点和工作示例。
如果您更喜欢 Table API,Table & SQL Connectors - Parquet Format 可能会有所帮助。
【讨论】: