fixes

Signed-off-by: Robert Kruszewski <github@robertk.io>

Author: robert3005

java/vortex-jni/src/test/java/dev/vortex/jni/JNIWriterTest.java

@@ -84,6 +84,22 @@ public void testCreateWriterPlainLocalPath() throws IOException {
         assertTrue(Files.exists(outputPath), "output file should exist");
     }
 
+    @Test
+    public void testCreateWriterCreatesParentDirectories() throws IOException {
+        Path outputPath = tempDir.resolve("nested/sub/dir/test_create_nested.vortex");
+        String writePath = outputPath.toAbsolutePath().toUri().toString();
+
+        BufferAllocator allocator = ArrowAllocation.rootAllocator();
+        Map<String, String> options = new HashMap<>();
+
+        Session session = Session.create();
+        try (VortexWriter writer = VortexWriter.create(session, writePath, personSchema(), options, allocator)) {
+            assertNotNull(writer);
+        }
+
+        assertTrue(Files.exists(outputPath), "output file should exist");
+    }
+
     @Test
     public void testWriteBatch() throws IOException {
         Path outputPath = tempDir.resolve("test_ffi.vortex");

vortex-jni/src/writer.rs

@@ -181,6 +181,9 @@ pub extern "system" fn Java_dev_vortex_jni_NativeWriter_create(
         let handle = session.handle().spawn(async move {
             match target {
                 WriteTarget::Local(path) => {
+                    if let Some(parent) = path.parent().filter(|p| !p.as_os_str().is_empty()) {
+                        async_fs::create_dir_all(parent).await?;
+                    }
                     let mut file = File::create(path).await?;
                     let summary = session.write_options().write(&mut file, stream).await?;
                     file.shutdown().await?;