feat: add convert_to_delta

Add a convert_to_delta operation for converting a Parquet table to a Delta Table in place.
delta-io · Nov 1, 2023 · 4265e4f · 4265e4f
1 parent 60d757f
commit 4265e4f
Show file tree

Hide file tree

Showing 6 changed files with 830 additions and 2 deletions.
diff --git a/crates/deltalake-core/src/lib.rs b/crates/deltalake-core/src/lib.rs
@@ -126,6 +126,9 @@ pub use protocol::checkpoints;
 #[cfg(feature = "integration_test")]
 pub mod test_utils;
 
+#[cfg(feature = "parquet")]
+const NULL_PARTITION_VALUE_DATA_PATH: &str = "__HIVE_DEFAULT_PARTITION__";
+
 /// Creates and loads a DeltaTable from the given path with current metadata.
 /// Infers the storage backend to use from the scheme in the given table path.
 pub async fn open_table(table_uri: impl AsRef<str>) -> Result<DeltaTable, DeltaTableError> {