-
Notifications
You must be signed in to change notification settings - Fork 319
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Support for DeltaTable #236
Conversation
…/delta_binding
…/delta_binding
src/csharp/Microsoft.Spark.E2ETest/Microsoft.Spark.E2ETest.csproj
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta.UnitTest/DeltaTableTests.cs
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta.UnitTest/DeltaTableTests.cs
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta.UnitTest/DeltaTableTests.cs
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta.UnitTest/DeltaTableTests.cs
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta.UnitTest/DeltaTableTests.cs
Outdated
Show resolved
Hide resolved
...p/Microsoft.Spark.Extensions.Delta.UnitTest/Microsoft.Spark.Extensions.Delta.UnitTest.csproj
Outdated
Show resolved
Hide resolved
...p/Microsoft.Spark.Extensions.Delta.UnitTest/Microsoft.Spark.Extensions.Delta.UnitTest.csproj
Outdated
Show resolved
Hide resolved
...p/Microsoft.Spark.Extensions.Delta.UnitTest/Microsoft.Spark.Extensions.Delta.UnitTest.csproj
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta/Tables/DeltaMergeBuilder.cs
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please fix unit test failures.
@@ -0,0 +1,11 @@ | |||
<Project Sdk="Microsoft.NET.Sdk"> |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@rapoth the package version should be follow the delta package version, not Spark .NET version right?
src/csharp/Microsoft.Spark.Extensions.Delta/Tables/DeltaTable.cs
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta/Tables/DeltaTable.cs
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta/Tables/DeltaTable.cs
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta/Tables/DeltaTable.cs
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta/Tables/DeltaTable.cs
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta/Tables/DeltaTable.cs
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta/Tables/DeltaTable.cs
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta/Tables/DeltaTable.cs
Outdated
Show resolved
Hide resolved
@AFFogarty most likely failing due to missing delta jar. I would start by looking here and probably download and add the delta jars to each spark distro(where applicable). |
src/csharp/Microsoft.Spark.Extensions.Delta.UnitTest/DeltaTableTests.cs
Outdated
Show resolved
Hide resolved
src/csharp/Microsoft.Spark.Extensions.Delta.UnitTest/DeltaTableTests.cs
Outdated
Show resolved
Hide resolved
…eTests.cs Co-Authored-By: Steve Suh <suhsteve@gmail.com>
…eTests.cs Co-Authored-By: Steve Suh <suhsteve@gmail.com>
…eTests.cs Co-Authored-By: Steve Suh <suhsteve@gmail.com>
src/csharp/Microsoft.Spark.Extensions.Delta.UnitTest/DeltaTableTests.cs
Outdated
Show resolved
Hide resolved
…eTests.cs Co-Authored-By: Steve Suh <suhsteve@gmail.com>
…DeltaMergeBuilder.cs Co-Authored-By: Steve Suh <suhsteve@gmail.com>
…spark into feature/delta_binding
…/delta_binding
Using
|
src/csharp/Extensions/Microsoft.Spark.Extensions.Delta.E2ETest/DeltaTableTests.cs
Outdated
Show resolved
Hide resolved
</ItemGroup> | ||
|
||
<PropertyGroup> | ||
<InternalsAssemblyNames>Microsoft.Spark;Microsoft.Spark.E2ETest</InternalsAssemblyNames> |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Do you need internal classes of Microsoft.Spark here? What are they?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
We need it for Microsoft.Spark.Versions
.
…/delta_binding
…/delta_binding
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for working on this @AFFogarty. I have few minor comments.
src/csharp/Extensions/Microsoft.Spark.Extensions.Delta.E2ETest/DeltaFixture.cs
Outdated
Show resolved
Hide resolved
...ons/Microsoft.Spark.Extensions.Delta.E2ETest/Microsoft.Spark.Extensions.Delta.E2ETest.csproj
Outdated
Show resolved
Hide resolved
src/csharp/Extensions/Microsoft.Spark.Extensions.Delta.E2ETest/SparkCollection.cs
Outdated
Show resolved
Hide resolved
src/csharp/Extensions/Microsoft.Spark.Extensions.Delta.E2ETest/DeltaFixture.cs
Show resolved
Hide resolved
src/csharp/Extensions/Microsoft.Spark.Extensions.Delta.E2ETest/DeltaTableTests.cs
Outdated
Show resolved
Hide resolved
src/csharp/Extensions/Microsoft.Spark.Extensions.Delta.E2ETest/DeltaTableTests.cs
Outdated
Show resolved
Hide resolved
Addressed all comments. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
This PR adds support for
DeltaTable
, which provides CRUD operations for Delta tables.This PR introduces a new project called
Microsoft.Spark.Extensions.Delta
. This new project will contain all of the code related to Delta support in .Net. If we want to add support for other third-party libraries, we will create new projects in theMicrosoft.Spark.Extensions
namespace.The tests require the Delta Jar to be installed in the
$SPARK_HOME/jars/
directory.