Skip to content
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

[Spark] UniForm supports using Hive Metastore #2120

Closed
wants to merge 1 commit into from

Conversation

harperjiang
Copy link
Contributor

@harperjiang harperjiang commented Sep 28, 2023

UniForm will migrate to use HMS to store Iceberg table data by Hao Jiang [email protected]

Which Delta project/connector is this regarding?

  • Spark
  • Standalone
  • Flink
  • Kernel
  • Other (fill in here)

Description

Allow UniForm to use Hive metastore when converting to iceberg tables

How was this patch tested?

Update existing test cases

Does this PR introduce any user-facing changes?

No

  UniForm HMS Migration by Hao Jiang <[email protected]>
Copy link
Contributor

@lzlfred lzlfred left a comment

Choose a reason for hiding this comment

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

LGTM !

@vkorukanti vkorukanti closed this in 01fee68 Oct 2, 2023
vkorukanti pushed a commit to vkorukanti/delta that referenced this pull request Oct 3, 2023
UniForm will use HMS as catalog instead of using file system.

Closes delta-io#2120

GitOrigin-RevId: f2d863c6e91e4d5d8c2e0f373f4c0c4ad9956fb6
vkorukanti pushed a commit to vkorukanti/delta that referenced this pull request Oct 3, 2023
UniForm will use HMS as catalog instead of using file system.

Closes delta-io#2120

GitOrigin-RevId: f2d863c6e91e4d5d8c2e0f373f4c0c4ad9956fb6
Kimahriman pushed a commit to Kimahriman/delta that referenced this pull request Oct 3, 2023
UniForm will use HMS as catalog instead of using file system.

Closes delta-io#2120

GitOrigin-RevId: f2d863c6e91e4d5d8c2e0f373f4c0c4ad9956fb6
@VisibleForTesting
void persistTable(Table hmsTable, boolean updateHiveTable)
throws TException, InterruptedException {
+ hmsTable.getSd().setCols(Collections.singletonList(new FieldSchema("col", "array<string>", "")));

Choose a reason for hiding this comment

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

why is this required, can't we just store empty cols ?

Comment on lines +23 to +25
+ StorageDescriptor newsd = storageDescriptor(metadata, hiveEngineEnabled);
+ newsd.getSerdeInfo().setParameters(tbl.getSd().getSerdeInfo().getParameters());
+ tbl.setSd(newsd); // set to pickup any schema changes

Choose a reason for hiding this comment

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

why is this required for iceberg ?

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