parquet-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject parquet-cpp git commit: PARQUET-763: C++: Expose ParquetFileReader through Arrow reader
Date Fri, 04 Nov 2016 07:20:03 GMT
Repository: parquet-cpp
Updated Branches:
  refs/heads/master be20e2e03 -> 954f63a1b


PARQUET-763: C++: Expose ParquetFileReader through Arrow reader

Author: Uwe L. Korn <uwelk@xhochy.com>

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 <uwelk@xhochy.com>
Authored: Fri Nov 4 08:18:14 2016 +0100
Committer: Uwe L. Korn <uwelk@xhochy.com>
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:


Mime
View raw message