Skip to content

Upgrade DataFusion to version 56 - #1826

Open
nuno-faria wants to merge 3 commits into
apache:mainfrom
nuno-faria:upgrade_datafusion_56
Open

nuno-faria wants to merge 3 commits into
apache:mainfrom
nuno-faria:upgrade_datafusion_56

Conversation

@nuno-faria

Copy link
Copy Markdown
Contributor

Which issue does this PR close?

N/A.

Rationale for this change

A new DataFusion version is being released: apache/datafusion#24461

What changes are included in this PR?

There are new types like Show (which replaced DescribeTable), AsOfJoin, and MaterializedCte, as well as some other minor changes. I will add them as comments.

Are there any user-facing changes?

New DF version. Other than that the main breaking change is that DescribeTable has been removed. I added a note to the upgrade guide.

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

}

/// Retrieves the right input `LogicalPlan` to this `Join` node
/// Retrieves the equality keys of this `Join` node

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

Noticed when creating the ASOF join that the prev comment was wrong.

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

&self,
_ctx: &dyn Session,
projection: Option<&Vec<usize>>,
projection: Option<&[usize]>,

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

Comment on lines 5352 to +5388
@@ -5385,7 +5385,7 @@ def map_entries(map: Expr) -> Expr:
def element_at(map: Expr, key: Expr) -> Expr:
"""Returns the value for a given key in the map.
Returns ``[None]`` if the key is absent.
Returns ``[]`` if the key is absent.

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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


def test_sql_with_options_no_statements(ctx):
sql = "SET time zone = 1;"
sql = "SET time zone = 'UTC';"

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

Timezone is now validated.

Comment on lines 1792 to +1814
@@ -1811,7 +1811,7 @@ def test_read_csv_with_options(tmp_path, as_read, global_ctx):
[
pa.array(["Alice", "Bob", "Phil", "Karin"]),
pa.array([30.0, 25.0, 75.0, 50.0]),
pa.array(["New York; NY", None, "Detroit' MI", "Stockholm\nSweden"]),
pa.array(["New York; NY", "", "Detroit' MI", "Stockholm\nSweden"]),

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

This now appears as an empty string since it does not match the null_regex. From apache/datafusion#25254

Comment on lines +2722 to +2724
with pytest.raises(
Exception, match=r"Invalid compression level \d+ for \w+\. Expected a level"
):

Copy link
Copy Markdown
Contributor Author

Choose a reason for hiding this comment

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

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.

1 participant