Hi Giannis:
I think this is due to the User Defined AsyncTableFunction have
not been supported yet. It has a little different in type inference.
I just opened a thread discuss about supporting this feature, you can
refer to: https://lists.apache.org/thread/7vk1799ryvrz4lsm5254q64ctm89mx2l
Than
What im curious is about the completable future in the function signature
(eval)
public final void eval(CompletableFuture> future,
Object... keys)
is is injected automatically?
Best
On Mon, May 8, 2023 at 10:02 AM Giannis Polyzos
wrote:
> Hi Biao,
> yeah, this means that since it's a Table Fun
Hi Biao,
yeah, this means that since it's a Table Function UDF, I need to combine it
with lateral correct?
I have tried both approaches to be honest. You can find attached the log
output with verbose=true for both queries
On Mon, May 8, 2023 at 9:49 AM Biao Geng wrote:
> Hi Giannis,
> Would you
Hi Giannis,
Would you mind executing SET 'sql-client.verbose' = 'true';. first in your
SQL client and then run the above example to show the error output in the
SQL client?
For the complete example, you can refer to codes of
HBaseRowDataAsyncLookupFunction.
Besides, in your example, you actually im
Yes I have and the function is present in the catalog.
And I have other udfs also registered, I’m just having issues with the
Async one and can’t really find any examples.
Best
On Mon, 8 May 2023 at 3:46 AM, Shammon FY wrote:
> Hi Giannis,
>
> Have you use "CREATE FUNCTION asyncfn AS 'Your full
Hi Giannis,
Have you use "CREATE FUNCTION asyncfn AS 'Your full class name of async
function class'" or "CREATE TEMPORARY FUNCTION asyncfn AS 'Your full class
name of async function class'" to create a customized function named
"asyncfn" before it is used in your sql?
The error message "No match
I can't really find any examples / docs for Flink's AsyncTableFunction and
I have a hard time getting it to work.
Is there any example you can share that just takes as input a String key
and outputs lets say a record (returned by the lookup?)
Also is not clear to me how the async happens internally
