(&self, partition_bytes: &[u8])
| 579 | } |
| 580 | |
| 581 | fn resolve_partition_path(&self, partition_bytes: &[u8]) -> Result<String> { |
| 582 | if self.partition_keys.is_empty() { |
| 583 | Ok(String::new()) |
| 584 | } else { |
| 585 | let row = BinaryRow::from_serialized_bytes(partition_bytes)?; |
| 586 | self.partition_computer.generate_partition_path(&row) |
| 587 | } |
| 588 | } |
| 589 | |
| 590 | /// Create an append-only writer for non-PK tables. |
| 591 | fn create_append_writer(&self, partition_path: String, bucket: i32) -> Result<FileWriter> { |
no test coverage detected