Repository: parquet-cpp Updated Branches: refs/heads/master be20e2e03 -> 954f63a1b
PARQUET-763: C++: Expose ParquetFileReader through Arrow reader Author: Uwe L. Korn <[email protected]> Closes #184 from xhochy/PARQUET-763 and squashes the following commits: 5fe3179 [Uwe L. Korn] PARQUET-763: C++: Expose ParquetFileReader through Arrow reader Project: http://git-wip-us.apache.org/repos/asf/parquet-cpp/repo Commit: http://git-wip-us.apache.org/repos/asf/parquet-cpp/commit/954f63a1 Tree: http://git-wip-us.apache.org/repos/asf/parquet-cpp/tree/954f63a1 Diff: http://git-wip-us.apache.org/repos/asf/parquet-cpp/diff/954f63a1 Branch: refs/heads/master Commit: 954f63a1b9ff7e54dd4971a4dacb6e09e0c941ef Parents: be20e2e Author: Uwe L. Korn <[email protected]> Authored: Fri Nov 4 08:18:14 2016 +0100 Committer: Uwe L. Korn <[email protected]> Committed: Fri Nov 4 08:18:14 2016 +0100 ---------------------------------------------------------------------- src/parquet/arrow/reader.cc | 5 +++++ src/parquet/arrow/reader.h | 2 ++ 2 files changed, 7 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/parquet-cpp/blob/954f63a1/src/parquet/arrow/reader.cc ---------------------------------------------------------------------- diff --git a/src/parquet/arrow/reader.cc b/src/parquet/arrow/reader.cc index c581997..a706cc2 100644 --- a/src/parquet/arrow/reader.cc +++ b/src/parquet/arrow/reader.cc @@ -70,6 +70,7 @@ class FileReader::Impl { Status GetFlatColumn(int i, std::unique_ptr<FlatColumnReader>* out); Status ReadFlatColumn(int i, std::shared_ptr<Array>* out); Status ReadFlatTable(std::shared_ptr<Table>* out); + const ParquetFileReader* parquet_reader() { return reader_.get(); } private: MemoryPool* pool_; @@ -222,6 +223,10 @@ Status FileReader::ReadFlatTable(std::shared_ptr<Table>* out) { return impl_->ReadFlatTable(out); } +const ParquetFileReader* FileReader::parquet_reader() { + return impl_->parquet_reader(); +} + FlatColumnReader::Impl::Impl(MemoryPool* pool, const ColumnDescriptor* descr, ParquetFileReader* reader, int column_index) : pool_(pool), http://git-wip-us.apache.org/repos/asf/parquet-cpp/blob/954f63a1/src/parquet/arrow/reader.h ---------------------------------------------------------------------- diff --git a/src/parquet/arrow/reader.h b/src/parquet/arrow/reader.h index 7028be4..dc144f4 100644 --- a/src/parquet/arrow/reader.h +++ b/src/parquet/arrow/reader.h @@ -100,6 +100,8 @@ class PARQUET_EXPORT FileReader { // Read a table of flat columns into a Table. ::arrow::Status ReadFlatTable(std::shared_ptr<::arrow::Table>* out); + const ParquetFileReader* parquet_reader(); + virtual ~FileReader(); private:
