Aditya created SAMZA-2014:
-----------------------------
Summary: Samza-sql: Support table as both source (for join) and
destination in the same application
Key: SAMZA-2014
URL: https://issues.apache.org/jira/browse/SAMZA-2014
Project: Samza
Issue Type: Bug
Reporter: Aditya
Assignee: Aditya
A query like below need to be supported:
INSERT INTO espresso.mydb.mytable
SELECT tbl.__key__ as __key__, strm.field as field
FROM espresso.mydb.mytable tbl
RIGHT JOIN kafka.system.mytopic strm ON tbl.__key__ = strm.foreignkey
WHERE tbl.field != strm.field
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
