DeltaIO 0.0.0-pre.5

Delta.IO

This is an ongoing attempt to implement delta.io in pure .net with no native dependencies, wrappers and so on.

Why implement the Delta Lake transaction log protocol in .NET?

Delta Spark depends on Java and Spark, which is fine for many use cases, but not all Delta Lake users want to depend on these libraries. This library allows using Delta Lake in C# or other languages using .NET runtime.

It lets you query Delta tables with blazing speed without depending on Java/Scala.

Suppose you want to query a Delta table with on your local machine. This library makes it easy to query the table with a simple dotnet add package command - no need to install Java or Spark.

This library heavily relies on parquet-dotnet - a fast, safe, pure parquet implementation in .NET, for reading delta log checkpoints and the data itself.

Delta lake for idiots (like myself)

Delta lake essentially stores data as a set of parquet files. When you add a set of rows to the delta lake table, it essentially adds more parquet files. The problem is only to figure out which files to read.

Sometimes delta tables will be "compacted" to minimise the number of files and reorganise the storage for more efficiency, especially if those files are small and there are a lot of them.

When you delete rows from a delta lake table, some files will be deleted. But wait, what happens if you want to delete one row, and the file it's in contains other rows as well? In that case delta lake will mark the file as deleted, and create a new file without that row.

So the purpose of the delta lake library like this is to figure out which files are relevant.

Delta tables also support versioning, because files are kept for reasons of time travel. So that you can tell which files were relevant at specific point of time.

Status

Still early stages.

This library can already read and parse delta log for simple unpartitioned tables, but it's still a way to go.

The aim of the first version is to fully support reading the lake, with next version to support modification operations as well.

Quick start

After installing the nuget package , find out type of storage your tables are stored in. We will stick with local disk here, but there are plenty of other options.

using DeltaLake;

// open table from the local disk
Table table = new Table("c:/table/folder");

This will instantiate an interface to the delta table, so you can start performing other operations.

Reading

To figure out which files are valid for current delta table, call the following method:

IReadOnlyCollection<string> files = await table.GetFilesAsync();

This returns the list of files at the latest version of this table, which are a relative path from the root of the delta table.

Appending

Stay tuned!

Deleting

Tune in!

Contributing

Bookmark, star, start discussions, spread the word if you are interested in the future of this project! You can also donate to the project if you find it useful.

Useful Links

• Delta Transaction Log Protocol.
• Delta Kernel.
• Integration Test Dataset.
• Alternative implementations
  • delta-net - an early prototype as of late 2024.
  • delta-dotnet - as of end of 2024 a promising incubator project, which is essentially a wrapper around delta-rs.
• Chinook database used in generating test delta tables.