Hi Gou, CsvSchema uses java.io.File API to scan a directory and doesn't speak HDFS directly (nor does it accept generic java.io.Reader to construct it).
Is there a way for you to mount HDFS using FUSE ? Example MountableHDFS <https://wiki.apache.org/hadoop/MountableHDFS>. Regards, Andrei. On Thu, Mar 7, 2019 at 9:10 PM 勾王敏浩 <gwm...@mails.tsinghua.edu.cn> wrote: > Hello, everyone. > This is Wangminhao Gou. I have an urgent need now. I want to read CSV > files from remote HDFS and parse them using calcite. Now that I can use a > file stream to get this CSV file, and understand how to use calcite to make > a relational table of the local csv, what should I do next? > Looking forward to your reply. > Best, > Wangminhao Gou