Fix compilation errors.

mathworks · Dec 4, 2024 · 75902fe · 75902fe
1 parent 9396088
commit 75902fe
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 6 deletions.
diff --git a/matlab/src/cpp/arrow/matlab/io/ipc/proxy/record_batch_stream_reader.cc b/matlab/src/cpp/arrow/matlab/io/ipc/proxy/record_batch_stream_reader.cc
@@ -32,7 +32,7 @@ RecordBatchStreamReader::RecordBatchStreamReader(
   REGISTER_METHOD(RecordBatchStreamReader, getSchema);
   REGISTER_METHOD(RecordBatchStreamReader, readRecordBatch);
   REGISTER_METHOD(RecordBatchStreamReader, hasNextRecordBatch);
-  REGISTER_METHOD(RecordBatchStreamReader, readTable);
+  // REGISTER_METHOD(RecordBatchStreamReader, readTable);
 }
 
 libmexclass::proxy::MakeResult RecordBatchStreamReader::make(
@@ -90,7 +90,6 @@ void RecordBatchStreamReader::readRecordBatch(
   mda::ArrayFactory factory;
   const auto record_batch_proxy_id_mda = factory.createScalar(record_batch_proxy_id);
   context.outputs[0] = record_batch_proxy_id_mda;
-  }
 }
 
 void RecordBatchStreamReader::hasNextRecordBatch(
@@ -100,8 +99,8 @@ void RecordBatchStreamReader::hasNextRecordBatch(
   if (!nextRecordBatch) {
 	  // Try to read another RecordBatch from the
 	  // IPC Stream.
-	  const auto maybe_record_batch = reader->Next();
-	  if (!maybe_record_batch) {
+	  auto maybe_record_batch = reader->Next();
+	  if (!maybe_record_batch.ok()) {
 		has_next_record_batch = false;
 	  } else {
 		// If we read a RecordBatch successfully,

diff --git a/matlab/src/cpp/arrow/matlab/io/ipc/proxy/record_batch_stream_reader.h b/matlab/src/cpp/arrow/matlab/io/ipc/proxy/record_batch_stream_reader.h
@@ -33,12 +33,12 @@ class RecordBatchStreamReader : public libmexclass::proxy::Proxy {
 
  protected:
   std::shared_ptr<arrow::ipc::RecordBatchStreamReader> reader;
-  std::shared_ptr<arrow::ipc::RecordBatchStreamReader> nextRecordBatch;
+  std::shared_ptr<arrow::RecordBatch> nextRecordBatch;
 
   void getSchema(libmexclass::proxy::method::Context& context);
   void readRecordBatch(libmexclass::proxy::method::Context& context);
   void hasNextRecordBatch(libmexclass::proxy::method::Context& context);
-  void readTable(libmexclass::proxy::method::Context& context);
+  // void readTable(libmexclass::proxy::method::Context& context);
 };
 
 }  // namespace arrow::matlab::io::ipc::proxy