@@ -83,14 +83,14 @@ pub extern "system" fn Java_org_lance_Fragment_createWithFfiArray<'local>(
8383 dataset_uri : JString ,
8484 arrow_array_addr : jlong ,
8585 arrow_schema_addr : jlong ,
86- max_rows_per_file : JObject , // Optional<Integer>
87- max_rows_per_group : JObject , // Optional<Integer>
88- max_bytes_per_file : JObject , // Optional<Long>
89- mode : JObject , // Optional<String>
90- enable_stable_row_ids : JObject , // Optional<Boolean>
91- data_storage_version : JObject , // Optional<String>
92- storage_options_obj : JObject , // Map<String, String>
93- storage_options_provider_obj : JObject , // Optional<StorageOptionsProvider>
86+ max_rows_per_file : JObject , // Optional<Integer>
87+ max_rows_per_group : JObject , // Optional<Integer>
88+ max_bytes_per_file : JObject , // Optional<Long>
89+ mode : JObject , // Optional<String>
90+ enable_stable_row_ids : JObject , // Optional<Boolean>
91+ data_storage_version : JObject , // Optional<String>
92+ storage_options_obj : JObject , // Map<String, String>
93+ storage_options_provider_obj : JObject , // Optional<StorageOptionsProvider>
9494 allow_external_blob_outside_bases : JObject , // Optional<Boolean>
9595) -> JObject < ' local > {
9696 ok_or_throw_with_return ! (
@@ -120,14 +120,14 @@ fn inner_create_with_ffi_array<'local>(
120120 dataset_uri : JString ,
121121 arrow_array_addr : jlong ,
122122 arrow_schema_addr : jlong ,
123- max_rows_per_file : JObject , // Optional<Integer>
124- max_rows_per_group : JObject , // Optional<Integer>
125- max_bytes_per_file : JObject , // Optional<Long>
126- mode : JObject , // Optional<String>
127- enable_stable_row_ids : JObject , // Optional<Boolean>
128- data_storage_version : JObject , // Optional<String>
129- storage_options_obj : JObject , // Map<String, String>
130- storage_options_provider_obj : JObject , // Optional<StorageOptionsProvider>
123+ max_rows_per_file : JObject , // Optional<Integer>
124+ max_rows_per_group : JObject , // Optional<Integer>
125+ max_bytes_per_file : JObject , // Optional<Long>
126+ mode : JObject , // Optional<String>
127+ enable_stable_row_ids : JObject , // Optional<Boolean>
128+ data_storage_version : JObject , // Optional<String>
129+ storage_options_obj : JObject , // Map<String, String>
130+ storage_options_provider_obj : JObject , // Optional<StorageOptionsProvider>
131131 allow_external_blob_outside_bases : JObject , // Optional<Boolean>
132132) -> Result < JObject < ' local > > {
133133 let c_array_ptr = arrow_array_addr as * mut FFI_ArrowArray ;
@@ -165,14 +165,14 @@ pub extern "system" fn Java_org_lance_Fragment_createWithFfiStream<'a>(
165165 _obj : JObject ,
166166 dataset_uri : JString ,
167167 arrow_array_stream_addr : jlong ,
168- max_rows_per_file : JObject , // Optional<Integer>
169- max_rows_per_group : JObject , // Optional<Integer>
170- max_bytes_per_file : JObject , // Optional<Long>
171- mode : JObject , // Optional<String>
172- enable_stable_row_ids : JObject , // Optional<Boolean>
173- data_storage_version : JObject , // Optional<String>
174- storage_options_obj : JObject , // Map<String, String>
175- storage_options_provider_obj : JObject , // Optional<StorageOptionsProvider>
168+ max_rows_per_file : JObject , // Optional<Integer>
169+ max_rows_per_group : JObject , // Optional<Integer>
170+ max_bytes_per_file : JObject , // Optional<Long>
171+ mode : JObject , // Optional<String>
172+ enable_stable_row_ids : JObject , // Optional<Boolean>
173+ data_storage_version : JObject , // Optional<String>
174+ storage_options_obj : JObject , // Map<String, String>
175+ storage_options_provider_obj : JObject , // Optional<StorageOptionsProvider>
176176 allow_external_blob_outside_bases : JObject , // Optional<Boolean>
177177) -> JObject < ' a > {
178178 ok_or_throw_with_return ! (
@@ -200,14 +200,14 @@ fn inner_create_with_ffi_stream<'local>(
200200 env : & mut JNIEnv < ' local > ,
201201 dataset_uri : JString ,
202202 arrow_array_stream_addr : jlong ,
203- max_rows_per_file : JObject , // Optional<Integer>
204- max_rows_per_group : JObject , // Optional<Integer>
205- max_bytes_per_file : JObject , // Optional<Long>
206- mode : JObject , // Optional<String>
207- enable_stable_row_ids : JObject , // Optional<Boolean>
208- data_storage_version : JObject , // Optional<String>
209- storage_options_obj : JObject , // Map<String, String>
210- storage_options_provider_obj : JObject , // Optional<StorageOptionsProvider>
203+ max_rows_per_file : JObject , // Optional<Integer>
204+ max_rows_per_group : JObject , // Optional<Integer>
205+ max_bytes_per_file : JObject , // Optional<Long>
206+ mode : JObject , // Optional<String>
207+ enable_stable_row_ids : JObject , // Optional<Boolean>
208+ data_storage_version : JObject , // Optional<String>
209+ storage_options_obj : JObject , // Map<String, String>
210+ storage_options_provider_obj : JObject , // Optional<StorageOptionsProvider>
211211 allow_external_blob_outside_bases : JObject , // Optional<Boolean>
212212) -> Result < JObject < ' local > > {
213213 let stream_ptr = arrow_array_stream_addr as * mut FFI_ArrowArrayStream ;
@@ -233,14 +233,14 @@ fn inner_create_with_ffi_stream<'local>(
233233fn create_fragment < ' a > (
234234 env : & mut JNIEnv < ' a > ,
235235 dataset_uri : JString ,
236- max_rows_per_file : JObject , // Optional<Integer>
237- max_rows_per_group : JObject , // Optional<Integer>
238- max_bytes_per_file : JObject , // Optional<Long>
239- mode : JObject , // Optional<String>
240- enable_stable_row_ids : JObject , // Optional<Boolean>
241- data_storage_version : JObject , // Optional<String>
242- storage_options_obj : JObject , // Map<String, String>
243- storage_options_provider_obj : JObject , // Optional<StorageOptionsProvider>
236+ max_rows_per_file : JObject , // Optional<Integer>
237+ max_rows_per_group : JObject , // Optional<Integer>
238+ max_bytes_per_file : JObject , // Optional<Long>
239+ mode : JObject , // Optional<String>
240+ enable_stable_row_ids : JObject , // Optional<Boolean>
241+ data_storage_version : JObject , // Optional<String>
242+ storage_options_obj : JObject , // Map<String, String>
243+ storage_options_provider_obj : JObject , // Optional<StorageOptionsProvider>
244244 allow_external_blob_outside_bases : JObject , // Optional<Boolean>
245245 source : impl StreamingWriteSource ,
246246) -> Result < JObject < ' a > > {
0 commit comments