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:loveallah1...@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.
