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 index 1564fd7ad405f..d455813e1c4df 100644 --- 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 index e959d504b3ff7..fd59819a2d5a1 100644 --- 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 reader; - std::shared_ptr nextRecordBatch; + std::shared_ptr 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