Skip to content

Conversation

@AFFogarty
Copy link
Contributor

This small PR adds support for Delta Lake 0.8.0. This includes a new API DeltaTable.UpgradeTableProtocol().

suhsteve
suhsteve previously approved these changes Feb 11, 2021
Copy link
Member

@suhsteve suhsteve left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM. Thanks @AFFogarty !

suhsteve
suhsteve previously approved these changes Feb 11, 2021
Copy link
Contributor

@imback82 imback82 left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM (minor comments), thanks @AFFogarty!


Assert.IsType<DeltaTable>(DeltaTable.ForName(tableName));
Assert.IsType<DeltaTable>(DeltaTable.ForName(_spark, tableName));
DeltaTable table = Assert.IsType<DeltaTable>(DeltaTable.ForName(_spark, tableName));
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Assert.IsType<DeltaTable> not required if you are setting it to DeltaTable table.

Comment on lines 30 to 31
("spark.databricks.delta.minReaderVersion", "1"),
("spark.databricks.delta.minWriterVersion", "2")
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Is this required for upgradeTableProtocol? If so, could you add a comment?

@imback82 imback82 merged commit fe03c74 into dotnet:master Feb 12, 2021
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants