[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Flink table api


I am streaming mongodb oplog using kafka and flink and want to join
multiple tables using flink table api but i have some concerns like is it
possible to join streamed tables in flink and if yes then please provide me
some example of stream join using table API.

I gone through your dynamic table api doc. it is quit interesting but
haven't found any example tutorial how to implement dynamic table.

I have tried to implement table api join using pojo class but it is
giving org.apache.flink.table.api.TableException: Cannot generate a valid
execution plan for the given query

*Amol Suryawanshi*
Java Developer

*iProgrammer Solutions Pvt. Ltd.*

*Office 103, 104, 1st Floor Pride Portal,Shivaji Housing Society,
Bahiratwadi,Near Hotel JW Marriott, Off Senapati Bapat Road, Pune - 411016,
MH, INDIA.**Phone: +91 9689077510 | Skype: amols_iprogrammer*
www.iprogrammer.com <sachin@xxxxxxxxxxxxxxx>