Skip to content
This repository has been archived by the owner on Jun 14, 2024. It is now read-only.

Data Skipping Index Part 3-1: Utils #491

Merged
merged 3 commits into from
Aug 23, 2021
Merged

Conversation

clee704
Copy link

@clee704 clee704 commented Aug 22, 2021

What is the context for this pull request?

What changes were proposed in this pull request?

Implement utility classes and methods for the data skipping index application rule.

Does this PR introduce any user-facing change?

No

How was this patch tested?

Unit test

Comment on lines +28 to +37
"org.scalacheck" %% "scalacheck" % "1.14.2" % "test",
"org.apache.spark" %% "spark-catalyst" % sv % "test" classifier "tests",
"org.apache.spark" %% "spark-core" % sv % "test" classifier "tests",
"org.apache.spark" %% "spark-sql" % sv % "test" classifier "tests") ++
(if (sparkVersion < Version(3, 1, 0))
Seq("org.scalatest" %% "scalatest" % "3.0.5" % "test")
Seq("org.scalatest" %% "scalatest" % "3.0.8" % "test")
else
Seq("org.scalatest" %% "scalatest" % "3.2.7" % "test")) ++
Seq(
"org.scalatest" %% "scalatest" % "3.2.3" % "test",
"org.scalatestplus" %% "scalatestplus-scalacheck" % "3.1.0.0-RC2" % "test")) ++
Copy link
Author

@clee704 clee704 Aug 22, 2021

Choose a reason for hiding this comment

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

Changes were necessary to use ExpressionEvalHelper for unit test.

Utility classes and methods for the rule application.
@clee704 clee704 marked this pull request as ready for review August 22, 2021 12:32
@clee704 clee704 requested a review from sezruby August 22, 2021 12:32
Chungmin Lee added 2 commits August 24, 2021 02:34
Copy link
Collaborator

@sezruby sezruby 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!

import org.apache.spark.sql.{DataFrame, SparkSession}
import org.apache.spark.sql.catalyst.InternalRow
import org.apache.spark.sql.catalyst.analysis.UnresolvedAttribute
import org.apache.spark.sql.catalyst.expressions._
import org.apache.spark.sql.catalyst.expressions.codegen.{CodegenContext, ExprCode}
import org.apache.spark.sql.catalyst.plans.logical.{Aggregate, Project, Window}
import org.apache.spark.sql.catalyst.plans.logical.{Aggregate, Filter, LogicalPlan, Project, Window}
Copy link
Collaborator

Choose a reason for hiding this comment

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

nit: --

@sezruby sezruby merged commit b06cbdd into microsoft:master Aug 23, 2021
@clee704 clee704 self-assigned this Sep 1, 2021
@clee704 clee704 added the enhancement New feature or request label Sep 1, 2021
Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
enhancement New feature or request
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants