Xu Mingmin created BEAM-3171:
--------------------------------

             Summary: convert a join into lookup
                 Key: BEAM-3171
                 URL: https://issues.apache.org/jira/browse/BEAM-3171
             Project: Beam
          Issue Type: New Feature
          Components: dsl-sql
            Reporter: Xu Mingmin
            Assignee: Xu Mingmin


We use BeamSQL to run streaming jobs mostly, and  add a join_as_lookup 
improvement(internal branch) to cover the streaming-to-batch case(similar as 
[1]). I could submit a PR as experimental if people are interested. 

The rough solution is, if one source of join node implements 
{{BeamSeekableTable}} and the other is not, then the join node is converted to 
a fact-lookup operation.

Ref:
[1] 
https://docs.google.com/document/d/1B-XnUwXh64lbswRieckU0BxtygSV58hysqZbpZmk03A/edit?usp=sharing
 

[~xumingming] [~takidau] for any comments



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to