Create a postpone writer (KV format, no sorting/dedup, special file naming).
(&self, partition_path: String, bucket: i32)
| 629 | |
| 630 | /// Create a postpone writer (KV format, no sorting/dedup, special file naming). |
| 631 | fn create_postpone_writer(&self, partition_path: String, bucket: i32) -> FileWriter { |
| 632 | let data_file_prefix = format!("data-u-{}-s-0-w-", self.commit_user); |
| 633 | FileWriter::Postpone(PostponeFileWriter::new( |
| 634 | self.table.file_io().clone(), |
| 635 | PostponeWriteConfig { |
| 636 | table_location: self.table.location().to_string(), |
| 637 | partition_path, |
| 638 | bucket, |
| 639 | schema_id: self.schema_id, |
| 640 | target_file_size: self.target_file_size, |
| 641 | file_compression: self.file_compression.clone(), |
| 642 | file_compression_zstd_level: self.file_compression_zstd_level, |
| 643 | write_buffer_size: self.write_buffer_size, |
| 644 | file_format: self.file_format.clone(), |
| 645 | data_file_prefix, |
| 646 | }, |
| 647 | )) |
| 648 | } |
| 649 | |
| 650 | /// Create a key-value writer for PK tables with normal buckets. |
| 651 | async fn create_kv_writer( |
no test coverage detected