Re: How to Use AsyncLookupFunction

2024-06-10 Thread Krzysztof Chmielewski
Hi there Clenens. This one might be a little bit tricky. You can take a look: at https://github.com/getindata/flink-http-connector/blob/main/src/main/java/com/getindata/connectors/http/internal/table/lookup/AsyncHttpTableLookupFunction.java We implemented our http connector using assuncLookup

How to Use AsyncLookupFunction

2024-06-09 Thread Clemens Valiente
hi, how do I implement AsyncLookupFunctions correctly? I implemented a AsyncLookupFunction, the eval function has the following signature: https://nightlies.apache.org/flink/flink-docs-release-1.17/api/java/org/apache/flink/table/functions/AsyncLookupFunction.html eval(CompletableFuture> future,