delta-rs

A native Rust library for Delta Lake, with bindings into Python

APACHE-2.0 License

Downloads
5.6M
Stars
2K
Committers
79

Bot releases are hidden (Show)

delta-rs - python-v0.19.2: objectstore conditional put Latest Release

Published by ion-elgreco about 1 month ago

New features

Bug Fixes

Other Changes

New Contributors

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.19.1...python-v0.19.2

delta-rs - python-v0.19.1: separate IO runtime

Published by ion-elgreco 2 months ago

New features

Bug Fixes

Other Changes

New Contributors

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.19.0...python-v0.19.1

delta-rs - python-v0.19.0: complete CDF support, add column operation, faster MERGE

Published by ion-elgreco 2 months ago

Breaking changes!

Default writer engine has changed to rust. Replace your partition_filters with a predicate (sql) instead. PyArrow engine is deprecated now, and will be removed in v1.0.

Highlights

  • CDF support in write_deltalake, delete, and merge operation
  • Expired logs cleanup during post-commit. Can be disabled with delta.enableExpiredLogCleanup = false
  • Improved MERGE performance by using predicate non-partition columns min/max for prefiltering
  • ADD column operation
  • Speed up log parsing

Performance improvements

New features

Bug Fixes

Other Changes

New Contributors

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.18.2...python-v0.19.0

delta-rs - python-v0.18.2: HDFS support

Published by ion-elgreco 4 months ago

New features

Bug Fixes

Other Changes

New Contributors

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.18.1...python-v0.18.2

delta-rs - python-v0.18.1

Published by ion-elgreco 4 months ago

New features

Bug Fixes

Other Changes

New Contributors

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.18.0...python-v0.18.1

New features

Bug Fixes

Other Changes

New Contributors

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.17.4...python-v0.18.0

delta-rs - python-v0.17.4: stats collection according config

Published by ion-elgreco 5 months ago

New features

Bug Fixes

Other Changes

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.17.3...python-v0.17.4

delta-rs - python-v0.17.3: CDF read support

Published by ion-elgreco 6 months ago

New features

  • feat(rust): advance state in post commit by @ion-elgreco in #2396
  • feat: cdf reader for delta tables by @hntd187 in #2048
  • feat(python, rust): add OBJECT_STORE_CONCURRENCY_LIMIT setting for ObjectStoreFactory by @zZKato in #2458

Bug Fixes

  • fix(rust): handle 429 from GCS by @adriangb in #2454

Other changes

  • chore(rust): bump arrow v51 and datafusion v37.1 by @lasantosr in #2395

New Contributors

  • @adriangb made their first contribution in #2454
  • @zZKato made their first contribution in #2458

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.17.2...python-v0.17.3

delta-rs - rust-v0.17.3

Published by rtyler 6 months ago

rust-v0.17.3 (2024-05-01)

Full Changelog

Implemented enhancements:

  • Limit concurrent ObjectStore access to avoid resource limitations in constrained environments #2457
  • How to get a DataFrame in Rust? #2404
  • Allow checkpoint creation when partion column is "timestampNtz " #2381
  • is there a way to make writing timestamp_ntz optional #2339
  • Update arrow dependency #2328
  • Release GIL in deltalake.write_deltalake #2234
  • Unable to retrieve custom metadata from tables in rust #2153
  • Refactor commit interface to be a Builder #2131

Fixed bugs:

  • Handle rate limiting during write contention #2451
  • regression : delta.logRetentionDuration don't seems to be respected #2447
  • Issue writing to mounted storage in AKS using delta-rs library #2445
  • TableMerger - when_matched_delete() fails when Column names contain special characters #2438
  • Generic DeltaTable error: External error: Arrow error: Invalid argument error: arguments need to have the same data type - while merge data in to delta table #2423
  • Merge on predicate throw error on date colum: Unable to convert expression to string #2420
  • Writing Tables with Append mode errors if the schema metadata is different #2419
  • Logstore issues on AWS Lambda #2410
  • Datafusion timestamp type doesn't respect delta lake schema #2408
  • Compacting produces smaller row groups than expected #2386
  • ValueError: Partition value cannot be parsed from string. #2380
  • Very slow s3 connection after 0.16.1 #2377
  • Merge update+insert truncates a delta table if the table is big enough #2362
  • Do not add readerFeatures or writerFeatures keys under checkpoint files if minReaderVersion or minWriterVersion do not satisfy the requirements #2360
  • Create empty table failed on rust engine #2354
  • Getting error message when running in lambda: message: "Too many open files" #2353
  • Temporary files filling up _delta_log folder - increasing table load time #2351
  • compact fails with merged schemas #2347
  • Cannot merge into table partitioned by date type column on 0.16.3 #2344
  • Merge breaks using logical datatype decimal128 #2343
  • Decimal types are not checked against max precision/scale at table creation #2331
  • Merge update+insert truncates a delta table #2320
  • Extract add.stats_parsed with wrong type #2312
  • Process fails without error message when executing merge #2310
  • delta_rs don't seems to respect the row group size #2309
  • Auth error when running inside VS Code #2306
  • Unable to read deltatables with binary columns: Binary is not supported by JSON #2302
  • Schema evolution not coercing with Large arrow types #2298
  • Panic in deltalake_core::kernel::snapshot::log_segment::list_log_files_with_checkpoint::{{closure}} #2290
  • Checkpoint does not preserve reader and writer features for the table protocol. #2288
  • Z-Order with larger dataset resulting in memory error #2284
  • Successful writes return error when using concurrent writers #2279
  • Rust writer should raise when decimal types are incompatible (currently writers and puts table in invalid state) #2275
  • Generic DeltaTable error: Version mismatch with new schema merge functionality in AWS S3 #2262
  • DeltaTable is not resilient to corrupted checkpoint state #2258
  • Inconsistent units of time #2256
  • Partition column comparison is an assertion rather than if block with raise exception #2242
  • Unable to merge column names starting from numbers #2230
  • Merging to a table with multiple distinct partitions in parallel fails #2227
  • cleanup_metadata not respecting custom logRetentionDuration #2180
  • Merge predicate fails with a field with a space #2167
  • When_matched_update causes records to be lost with explicit predicate #2158
  • Merge execution time grows exponetially with the number of column #2107
  • _internal.DeltaError when merging #2084
delta-rs - python-v0.17.2

Published by ion-elgreco 6 months ago

What's Changed

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.17.1...python-v0.17.2

delta-rs - python-v0.17.1

Published by ion-elgreco 6 months ago

Bug Fixes

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.17.0...python-v0.17.1

delta-rs - python-v0.17.0: checkpoint hook

Published by ion-elgreco 6 months ago

New features

Bug Fixes

Other Changes

New Contributors

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.16.4...python-v0.17.0

delta-rs - python-v0.16.4

Published by ion-elgreco 7 months ago

Bug Fixes

Other Changes

New Contributors

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.16.3...python-v0.16.4

delta-rs - python-v0.16.3

Published by ion-elgreco 7 months ago

New features

Bug Fixes

Other Changes

New Contributors

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.16.2...python-v0.16.3

delta-rs - python-v0.16.2

Published by ion-elgreco 7 months ago

Bug Fixes

Other Changes

New Contributors

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.16.1...python-v0.16.2

delta-rs - python-v0.16.2

Published by ion-elgreco 7 months ago

Bug Fixes

Other Changes

New Contributors

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.16.1...python-v0.16.2

delta-rs - python-v0.16.1

Published by ion-elgreco 7 months ago

New features

Bug Fixes

Other Changes

New Contributors

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.16.0...python-v0.16.1

Performance improvements

Breaking changes

This version introduces timestampNtz datatype, this means if your writer before wrote timestamp with no timezones to a timestamp column, this will now fail. The new behavior is that you can only write timestamps with UTC time zone to timestamp primitive type.

New features

Bug Fixes

Other Changes

New Contributors

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.15.3...python-v0.16.0

delta-rs - rust-v0.17.0

Published by rtyler 8 months ago

⚠️ The release of 0.17.0 removes the legacy dynamodb lock functionality, AWS users must read these release notes! ⚠️

File handlers

The 0.17.0 release moves storage implementations into their own crates, such as
deltalake-aws. A consequence of that refactoring is that custom storage and
file scheme handlers must be registered/initialized at runtime. Storage
subcrates conventionally define a register_handlers function which performs
that task. Users may see errors such as:

thread 'main' panicked at /home/ubuntu/.cargo/registry/src/index.crates.io-6f17d22bba15001f/deltalake-core-0.17.0/src/table/builder.rs:189:48:
The specified table_uri is not valid: InvalidTableLocation("Unknown scheme: s3")
  • Users of the meta-crate (deltalake) can call the storage crate via: deltalake::aws::register_handlers(None); at the entrypoint for their code.
  • Users who adopt core and storage crates independently (e.g. deltalake-aws) can register via deltalake_aws::register_handlers(None);.

The AWS, Azure, and GCP crates must all have their custom file schemes registered in this fashion.

dynamodblock to S3DynamoDbLogStore

The locking mechanism is fundamentally different between deltalake v0.16.x and v0.17.0, starting with this release the deltalake and deltalake-aws crates this library now relies on the same protocol for concurrent writes on AWS as the Delta Lake/Spark implementation.

Fundamentally the DynamoDB table structure changes, which is documented here. The configuration of a Rust process should continue to use the AWS_S3_LOCKING_PROVIDER environment value of dynamodb. The new table must be specified with the DELTA_DYNAMO_TABLE_NAME environment or configuration variable, and that should name the new S3DynamoDbLogStore compatible DynamoDB table.

Because locking is required to ensure safe cconsistent writes, there is no iterative migration, 0.16 and 0.17 writers cannot safely coexist. The following steps should be taken when upgrading:

  1. Stop all 0.16.x writers
  2. Ensure writes are completed, and lock table is empty.
  3. Deploy 0.17.0 writers

Full Changelog

Implemented enhancements:

  • Expose the ability to compile DataFusion with SIMD #2118
  • Updating Table log retention configuration with write_deltalake silently changes nothing #2108
  • ALTER table, ALTER Column, Add/Modify Comment, Add/remove/rename partitions, Set Tags, Set location, Set TBLProperties #2088
  • Docs: Update docs for check constraints #2063
  • Don't ensure_table_uri when creating a table with_log_store #2036
  • Exposing custom_metadata in merge operation #2031
  • Support custom table properties via TableAlterer and write/merge #2022
  • Remove parquet2 crate support #2004
  • Merge operation that only touches necessary partitions #1991
  • store userMetadata on write operations #1990
  • Create Dask integration page #1956
  • Merge: Filtering on partitions #1918
  • Rethink the load_version and load_with_datetime interfaces #1910
  • docs: Delta Lake + Arrow Integration #1908
  • docs: Delta Lake + Polars integration #1906
  • Rethink decision to expose the public interface in namespaces #1900
  • Add documentation on how to build and run documentation locally #1893
  • Add API to create an empty Delta Lake table #1892
  • Implementing CHECK constraints #1881
  • Check Invariants are respecting table features for write paths #1880
  • Organize docs with single lefthand sidebar #1873
  • Make sure invariants are handled properly throughout the codebase #1870
  • Unable to use deltalake Schema in write_deltalake #1862
  • Add a Rust-backed engine for write_deltalake #1861
  • Run doctest in CI for Python API examples #1783
  • [RFC] Use arrow for checkpoint reading and state handling #1776
  • Expose Python exceptions in public module #1771
  • Expose cleanup_metadata or create_checkpoint_from_table_uri_and_cleanup to the Python API #1768
  • Expose convert_to_delta to Python API #1767
  • Add high-level checking for append-only tables #1759

Fixed bugs:

  • Row order no longer preserved after merge operation #2165
  • Error when reading delta table with IDENTITY column #2152
  • Merge on IS NULL condition doesn't work for empty table #2148
  • JsonWriter converts structured parsing error into plain string #2143
  • Pandas import error when merging tables #2112
  • test_repair_on_update broken in main #2109
  • WriteBuilder::with_input_execution_plan does not apply the schema to the log's metadata fields #2105
  • MERGE logical plan vs execution plan schema mismatch #2104
  • Partitions not pushed down #2090
  • Cant create empty table with write_deltalake #2086
  • Unexpected high costs on Google Cloud Storage #2085
  • Unable to read s3 table: Unknown scheme: s3 #2065
  • write_deltalake not respecting writer_properties #2064
  • Unable to read/write tables with the "gs" schema in the table_uri in 0.15.1 #2060
  • LockClient requiered error for S3 backend in 0.15.1 python #2057
  • Error while writing Pandas DataFrame to Delta Lake (S3) #2051
  • Error with dynamo locking provider on 0.15 #2034
  • Conda version 0.15.0 is missing files #2021
  • Rust panicking through Python library when a delete predicate uses a nullable field #2019
  • No snapshot or version 0 found, perhaps /Users/watsy0007/resources/test_table/ is an empty dir? #2016
  • Generic DeltaTable error: type_coercion in Struct column in merge operation #1998
  • Constraint expr not formatted during commit action #1971
  • .load_with_datetime() is incorrectly rounding to nearest second #1967
  • vacuuming log files #1965
  • Unable to merge uppercase column names #1960
  • Schema error: Invalid data type for Delta Lake: Null #1946
  • Python v0.14 wheel files not up to date #1945
  • python Release 0.14 is missing Windows wheels #1942
  • CI integration test fails randomly: test_restore_by_datetime #1925
  • Merge data freezes indefenetely #1920
  • Load DeltaTable from non-existing folder causing empty folder creation #1916
  • Reoptimizes merge bins with only 1 file, even though they have no effect. #1901
  • The Python Docs link in README.MD points to old docs #1898
  • optimize.compact() fails with bad schema after updating to pyarrow 8.0 #1889
  • Python build is broken on main #1856
  • Checkpoint error with Azure Synapse #1847
  • merge very slow compared to delete + append on larger dataset #1846
  • get_add_actions fails with deltalake 0.13 #1835
  • Handle PyArrow CVE-2023-47248 #1834
  • Delta-rs writer hangs with to many file handles open (Azure) #1832
  • Encountering NotATable("No snapshot or version 0 found, perhaps xxx is an empty dir?") #1831
  • write_deltalake is not creating checkpoints #1815
  • Problem writing tables in directory named with char ~ #1806
  • DeltaTable Merge throws in merging if there are uppercase in Schema. #1797
  • rust merge error - datafusion panics #1790
  • expose use_dictionary=False when writing Delta Table and running optimize #1772

Closed issues:

  • Is this print necessary? Can we remove this. #2110
  • Azure concurrent writes #2069
  • Fix docs deployment #1867
  • Add a header in old docs and direct users to new docs #1865
delta-rs - python-v0.15.3

Published by ion-elgreco 9 months ago

Bug Fixes

Other Changes

Full Changelog: https://github.com/delta-io/delta-rs/compare/python-v0.15.2...python-v0.15.3