[orc] branch master updated: ORC-608: Fix DecimalBench reader options

[jc...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

jcamacho pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/orc.git


The following commit(s) were added to refs/heads/master by this push:
     new aaaac5d  ORC-608: Fix DecimalBench reader options
aaaac5d is described below

commit aaaac5d38d9832b15c6eb21a9c7f73b25c4c44af
Author: Panos Garefalakis <pg...@cloudera.com>
AuthorDate: Wed Mar 4 13:23:59 2020 +0000

    ORC-608: Fix DecimalBench reader options
    
    Fixes #490
---
 .../hive/src/java/org/apache/orc/bench/hive/DecimalBench.java     | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/java/bench/hive/src/java/org/apache/orc/bench/hive/DecimalBench.java b/java/bench/hive/src/java/org/apache/orc/bench/hive/DecimalBench.java
index 0345035..ac09441 100644
--- a/java/bench/hive/src/java/org/apache/orc/bench/hive/DecimalBench.java
+++ b/java/bench/hive/src/java/org/apache/orc/bench/hive/DecimalBench.java
@@ -76,7 +76,7 @@ public class DecimalBench implements OrcBenchmark {
   /**
    * Abstract out whether we are writing short or long decimals
    */
-  interface Loader {
+  public interface Loader {
     /**
      * Load the data from the values array into the ColumnVector.
      * @param vector the output
@@ -220,7 +220,7 @@ public class DecimalBench implements OrcBenchmark {
     Path path;
     boolean[] include;
     Reader reader;
-    OrcFile.ReaderOptions options;
+    Reader.Options readerOptions;
 
     @Setup
     public void setup() throws IOException {
@@ -238,13 +238,13 @@ public class DecimalBench implements OrcBenchmark {
       reader = OrcFile.createReader(path,
           OrcFile.readerOptions(conf).filesystem(fs));
       // just read the decimal columns from the first stripe
-      reader.options().include(include).range(0, 1000);
+      readerOptions = reader.options().include(include).range(0, 1000);
     }
   }
 
   @Benchmark
   public void read(Blackhole blackhole, InputState state) throws Exception {
-    RecordReader rows = state.reader.rows();
+    RecordReader rows = state.reader.rows(state.readerOptions);
     while (rows.nextBatch(state.batch)) {
       blackhole.consume(state.batch);
     }