Hi，
Our business is to dynamically query (such as left join/right join) the
mysql / oracle database during the cep process, or is there any other way to
achieve this function?
________________________________
[email protected]
From: Dawid Wysakowicz<mailto:[email protected]>
Date: 2020-01-06 18:09
To: 郑 洁锋<mailto:[email protected]>; user<mailto:[email protected]>
Subject: Re: Using async io in cep
Hi,
You cannot use the Async IO as described here[1] in the CEP library, if that's
what you are asking for.
It is also not that straightforward to say what would an async processing in
that case mean. Primary use case for Async IO is to execute parallel
computations of independent data. In case of CEP it does not stand for
processing of records within a single key, as those assume strict ordering and
in general case depend on results of processing previous records. One could
think of asynchronous processing of records from different keys in a single
parallel instance, but that would require a careful key processing. If I am not
mistaken Async IO also does not support a stateful processing on a keyed stream.
Best,
Dawid
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/stream/operators/asyncio.html
On 06/01/2020 09:59, 郑 洁锋 wrote:
Hi，
Is there a way to use asynchronous io to query the database in the
process of cep?
________________________________
[email protected]<mailto:[email protected]>
