flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Kruse, Sebastian" <Sebastian.Kr...@hpi.de>
Subject RE: how can Combine between two dataset in on datset and execution more condition in the same time
Date Thu, 11 Jun 2015 15:28:47 GMT
Hi,

You might want to translate your SQL statement into an expression of the relational algebra
at first [1]. This expression can be expressed with Flink's operators in a straight-forward
manner.
In the end, it will look something like this:

Employees.filter(_.job_id = ...).join(departments.filter(_.location = ...).where("department_id").equalTo("department_id").apply(
(employee, department) => employee.last_name)

Cheers,
Sebastian

[1] http://en.wikipedia.org/wiki/Relational_algebra

-----Original Message-----
From: hagersaleh [mailto:loveallah1987@yahoo.com] 
Sent: Donnerstag, 11. Juni 2015 13:41
To: user@flink.apache.org
Subject: how can Combine between two dataset in on datset and execution more condition in
the same time

how can Combine between two dataset in on datset and execution more condition in the same
time Example SELECT employees.last_name FROM employees E, departments D WHERE (D.department_id
= E.department_id AND D.location = 2400)
   AND (E.job_id = 'AC_ACCOUNT' OR E.salary > 60000);




--
View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/how-can-Combine-between-two-dataset-in-on-datset-and-execution-more-condition-in-the-same-time-tp1605.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Mime
View raw message