Relative Content

Tag Archive for bigdataapache-flinkpyflink

how to process bigtable join with pyflink

There are two tables A and B in PostgreSQL, both of which have approximately tens of millions or billions of records. I want to use the batch mode of PyFlink to process the join results of these two tables. Can I use only one join statement to query? Or is there another way?
query sql like this: