DatabaseClient at async example

[Nicos Maris]

Hello,

I have a short question about the following example in your documentation.

https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/operators/asyncio.html

Which is the package and the maven dependency of the class DatabaseClient?

I am building a Proof of Concept based on the above documentation and mariaDB.

[Amit Jain]

Hi Nicos,

DatabaseClient is an example class to describe the asyncio concept. There is no interface/class for this client in Flink codebase. You can use any mariaDB client implementation which supports concurrent request to DB.

--

Cheers,

Amit 

On Wed, Oct 3, 2018 at 8:14 PM Nicos Maris <[hidden email]> wrote:

Hello,

I have a short question about the following example in your documentation.

https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/operators/asyncio.html

Which is the package and the maven dependency of the class DatabaseClient?

I am building a Proof of Concept based on the above documentation and mariaDB.

[Nicos Maris]

Thanks Amit.

I will start with the following and see how it goes.

 <dependency>

    <groupId>io.vertx</groupId>

    <artifactId>vertx-jdbc-client</artifactId>

    <version>3.3.3</version>

</dependency>

<dependency>

    <groupId>org.mariadb.jdbc</groupId>      <artifactId>mariadb-java-client</artifactId>

    <version>1.5.5</version>

</dependency>

On Wed, Oct 3, 2018, 10:11 PM Amit Jain <[hidden email]> wrote:

Hi Nicos,

DatabaseClient is an example class to describe the asyncio concept. There is no interface/class for this client in Flink codebase. You can use any mariaDB client implementation which supports concurrent request to DB.

--

Cheers,

Amit 

On Wed, Oct 3, 2018 at 8:14 PM Nicos Maris <[hidden email]> wrote:

Hello,

I have a short question about the following example in your documentation.

https://ci.apache.org/projects/flink/flink-docs-release-1.6/dev/stream/operators/asyncio.html

Which is the package and the maven dependency of the class DatabaseClient?

I am building a Proof of Concept based on the above documentation and mariaDB.