orc - apache 兽人阅读器关闭

Question

我正在使用 org.apache.orc.OrcFile.createReader 这个库可以很好地读取 Orc 文件，但我没有找到任何关闭方法。正常吗？

val fic=OrcFile.createReader(new Path(element), OrcFile.readerOptions(conf));
val  rows:RecordReader = fic.rows();
        while (rows.nextBatch(batch)) {
          println ("number of rows"+batch.size) 
        }
// fic.close ??

标签： orc

Answer 1

RecordReader确实有一个close()方法，我通过调用它解决了我的问题（“文件在另一个程序中打开”）。