Skip to content

[SPARK-4226][SQL] SparkSQL - Add support for subqueries in predicates('in' clause) #3249

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.

Sign up for GitHub

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

Closed
ravipesala wants to merge 13 commits into from
Closed

[SPARK-4226][SQL] SparkSQL - Add support for subqueries in predicates('in' clause) #3249

Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
0a41e91
Supporting subqueries inside where 'in' clause
ravipesala Nov 13, 2014
0134915
Added new expression class
ravipesala Nov 13, 2014
152fd23
Added documentation and fixed style issues.
ravipesala Dec 3, 2014
9e361df
Fixed style issue
ravipesala Dec 3, 2014
86a4430
Added more comments to the code.
ravipesala Dec 5, 2014
4ee8c18
Fixed style issues
ravipesala Dec 5, 2014
834acda
Fixed review comments
ravipesala Dec 21, 2014
f1b7d30
Fixed comments
ravipesala Dec 21, 2014
dc424df
Fixed review comments
ravipesala Jan 5, 2015
4afc469
Fixed compilation errors
ravipesala Feb 14, 2015
03db47b
Fixed compilation errors
ravipesala Feb 14, 2015
a27cca6
Fixed compilation issuses
ravipesala Feb 14, 2015
7653eee
Fixed test cases
ravipesala Feb 14, 2015
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Fixed style issues
  • Loading branch information
@ravipesala
ravipesala committed Feb 27, 2015
commit 4ee8c1877c762cb04dcd0aa941658dfa8aef3f6d
2 changes: 1 addition & 1 deletion sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/analysis/Analyzer.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -507,7 +507,7 @@ class Analyzer(catalog: Catalog,
// Replace the condition column names with alias names.
val transformedConds = condition.transform{
case a: Attribute if resolvedChild.resolve(a.name, resolver) != None =>
UnresolvedAttribute("subquery."+cache.get(a.name).get)
UnresolvedAttribute("subquery." + cache.get(a.name).get)
}
// Join the first projection column of subquery to the main query and add as condition
// TODO : We can avoid if the parent condition already has this condition.
Expand Down