Hello folks,
We are using flink 1.9 SQL API and we are NOT using blink planner. Our
platform users express their flink jobs as SQL queries. We currently have a
use case of asynchronously lookup data from third parties for every event
we read from kafka stream and populate additional fields which we use later
in our group bys.
We were trying to prototype the best way we can asynchronously enrich our
events and two options we could think of:
1. UDTF extending AsyncTableFunction and users can use these functions
as part of SQL query. But it seems like AsyncTableFunction cannot be used
as UDTF currently.
2. LookupableTableSource to access data in Temporal table but its only
supported in blink.
Can you please suggest any other options I can try out?
Thanks,
-spurthi
