add write method

Author: sgilmore10

matlab/src/cpp/arrow/matlab/io/ipc/proxy/record_batch_file_writer.cc

@@ -25,10 +25,12 @@
 
 #include "libmexclass/proxy/ProxyManager.h"
 
+#include <iostream>
+
 namespace arrow::matlab::io::ipc::proxy {
 
   RecordBatchFileWriter::RecordBatchFileWriter(std::shared_ptr<arrow::ipc::RecordBatchWriter> writer) : writer{std::move(writer)} {
-    REGISTER_METHOD(RecordBatchFileWriter, write_batch);
+    REGISTER_METHOD(RecordBatchFileWriter, writeBatch);
   }
 
 libmexclass::proxy::MakeResult RecordBatchFileWriter::make(
@@ -62,7 +64,7 @@ libmexclass::proxy::MakeResult RecordBatchFileWriter::make(
     return std::make_shared<RecordBatchFileWriterProxy>(std::move(writer));
   }
 
-  void RecordBatchFileWriter::write_batch(libmexclass::proxy::method::Context& context) {
+  void RecordBatchFileWriter::writeBatch(libmexclass::proxy::method::Context& context) {
     namespace mda = ::matlab::data;
     using RecordBatchProxy = ::arrow::matlab::tabular::proxy::RecordBatch;
 

matlab/src/cpp/arrow/matlab/io/ipc/proxy/record_batch_file_writer.h

@@ -33,7 +33,7 @@ class RecordBatchFileWriter : public libmexclass::proxy::Proxy {
 
   protected:
 
-    void write_batch(libmexclass::proxy::method::Context& context);
+    void writeBatch(libmexclass::proxy::method::Context& context);
 
     std::shared_ptr<arrow::ipc::RecordBatchWriter> writer;
 };

matlab/src/matlab/+arrow/+io/+ipc/RecordBatchFileWriter.m

@@ -29,7 +29,16 @@
                 schema(1, 1) arrow.tabular.Schema
             end
             args = struct(Filename=filename, SchemaProxyID=schema.Proxy.ID);
-            obj.Proxy = arrow.internal.proxy.create("arrow.io.csv.proxy.TableReader", args);
+            obj.Proxy = arrow.internal.proxy.create("arrow.io.ipc.proxy.RecordBatchFileWriter", args);
+        end
+
+        function write(obj, recordBatch)
+            arguments
+                obj(1, 1) arrow.io.ipc.RecordBatchFileWriter
+                recordBatch(1, 1) arrow.tabular.RecordBatch
+            end
+            args = struct(RecordBatchProxyID=recordBatch.Proxy.ID);
+            obj.Proxy.writeBatch(args);
         end
     end
 end