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

feat: add cube support #86

Merged
merged 8 commits into from
Sep 18, 2024
Merged

feat: add cube support #86

merged 8 commits into from
Sep 18, 2024

Conversation

richtia
Copy link
Contributor

@richtia richtia commented Sep 18, 2024

No description provided.

@richtia richtia marked this pull request as ready for review September 18, 2024 03:53
return spark_session_for_setup.table("userage")


class TestDataFrameDataScienceFunctions:
Copy link
Contributor

Choose a reason for hiding this comment

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

Sorry I had this wrong the actual DS abbreviation means Decision Support.

symbol.generated_fields.append(self.determine_name_for_grouping(grouping))
self._top_level_projects.append(field_reference(idx))

if rel.group_type == spark_relations_pb2.Aggregate.GroupType.GROUP_TYPE_GROUPBY:
Copy link
Contributor

Choose a reason for hiding this comment

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

Consider using match here.

Copy link
Contributor Author

Choose a reason for hiding this comment

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

updated

@@ -1312,6 +1296,62 @@ def convert_aggregate_relation(self, rel: spark_relations_pb2.Aggregate) -> alge

return algebra_pb2.Rel(aggregate=aggregate)

def handle_group_by_aggregations(self, rel: spark_relations_pb2.Aggregate,
Copy link
Contributor

Choose a reason for hiding this comment

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

This is more like "handle groupings and measures" -- this particular function will handle both groupby and cube.

Copy link
Contributor Author

Choose a reason for hiding this comment

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

changed to handle_grouping_and_measures

@richtia richtia merged commit 5213de9 into main Sep 18, 2024
18 checks passed
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.

2 participants