apache · westonpace · Dec 18, 2020 · Jan 4, 2021 · Jan 5, 2021 · Jan 5, 2021
diff --git a/c_glib/arrow-glib/reader.cpp b/c_glib/arrow-glib/reader.cpp
@@ -1592,6 +1592,7 @@ garrow_csv_reader_new(GArrowInputStream *input,
 
   auto arrow_reader =
     arrow::csv::TableReader::Make(arrow::default_memory_pool(),
+                                  arrow::io::AsyncContext(),
                                   arrow_input,
                                   read_options,
                                   parse_options,

diff --git a/cpp/examples/minimal_build/example.cc b/cpp/examples/minimal_build/example.cc
@@ -39,6 +39,7 @@ Status RunMain(int argc, char** argv) {
   ARROW_ASSIGN_OR_RAISE(
       auto csv_reader,
       arrow::csv::TableReader::Make(arrow::default_memory_pool(),
+                                    arrow::io::AsyncContext(),
                                     input_file,
                                     arrow::csv::ReadOptions::Defaults(),
                                     arrow::csv::ParseOptions::Defaults(),

diff --git a/cpp/src/arrow/CMakeLists.txt b/cpp/src/arrow/CMakeLists.txt
@@ -189,7 +189,6 @@ set(ARROW_SRCS
     util/future.cc
     util/int_util.cc
     util/io_util.cc
-    util/iterator.cc
     util/logging.cc
     util/key_value_metadata.cc
     util/memory.cc

diff --git a/cpp/src/arrow/csv/CMakeLists.txt b/cpp/src/arrow/csv/CMakeLists.txt
@@ -21,7 +21,8 @@ add_arrow_test(csv-test
                column_builder_test.cc
                column_decoder_test.cc
                converter_test.cc
-               parser_test.cc)
+               parser_test.cc
+               reader_test.cc)
 
 add_arrow_benchmark(converter_benchmark PREFIX "arrow-csv")
 add_arrow_benchmark(parser_benchmark PREFIX "arrow-csv")

diff --git a/cpp/src/arrow/csv/column_decoder.cc b/cpp/src/arrow/csv/column_decoder.cc
@@ -84,7 +84,7 @@ class ConcreteColumnDecoder : public ColumnDecoder {
     auto chunk_index = next_chunk_++;
     WaitForChunkUnlocked(chunk_index);
     // Move Future to avoid keeping chunk alive
-    return std::move(chunks_[chunk_index]).result();
+    return chunks_[chunk_index].MoveResult();
   }
 
  protected: