Hi Gaurav
I am not sure what you are trying to do here as you are naming two data frames
with the same name which would be a compilation error in java.
However, after trying to see what you are asking, as of what I understand your
question is.
You can do something like this;
> SqlContext sqlContext = new SQlContext(sc) // This will create a sqlcontext
> object to leverage spark-sql api.
DataFrame firstDataFrame =
sqlContext.read().jdbc(“url”,”(select * from employee) as emp”) // See here I
am throwing a sub query to select all the employee
/* Or I can also have a subquery like this "(select * from
employee as e where e.empid = 1) as emp". The subquery that you throw as a part
of
* parameters would be running inside the database that you are
connecting to using the url specified in the query.
DataFrame secondDataFrame =
sqlContext.read().jdbc(“url”,”(select * from department as d where d.deptid =
2) as dept”)
firstDataFrame.show();
secondDataFrame.show();
Please tell me if I cleared you query or I didn’t then please clarify your
question. Please ask me if you have any other question too.
Thanks
Regards
Rishabh Wadhawan
> On Feb 11, 2016, at 9:47 AM, Gaurav Agarwal <gaurav130...@gmail.com> wrote:
>
> SqlContext sContext = new SQlContext(sc)
> DataFrame df = sContext.load("jdbc","select * from employee"); // These
> queries will be the Map<String,String> with driver.
> DataFrame df = sContext.load("jdbc","select * from Dept");
