我有一堆.csv文件,我正在寻找将它们加载到SnowPark中的最简单的方法?我不知道需要哪些API。如果有人能告诉我API,或者提供一个很棒的代码示例。
.csv
谢谢
发布于 2022-01-05 14:36:09
我不认为您可以在一步内直接完成此操作,因为斯诺帕克没有相应的API。你能做的是:
将CSV文件加载到某个阶段。
// Upload a file to a stage. session.file.put("file:///tmp/file1.csv", "@myStage/prefix1")
通过从舞台上读取文件来创建DataFrame。
val dfCatalog = session.read.csv("@myStage/prefix1")
请参阅更多信息这里、这里和这里
https://stackoverflow.com/questions/70593758
相似问题