Dependency

Overview

The dws-connector-flink tool connects the GaussDB(DWS) client to Flink by encapsulating the GaussDB(DWS) client. Its import capability is equivalent to that of the GaussDB(DWS) client. The GaussDB(DWS) team created dws-connector-flink, and it will be continually improved to align with the GaussDB(DWS) database.

dws connector of dws-flink-connector supports only single concurrent query of inventory data and does not support concurrent read.

How to Use

• Introduced in Maven mode
  dws-connector-flink has been added to the Maven repository. You can select the latest version. For details, visit https://mvnrepository.com/artifact/com.huaweicloud.dws.

  <dependency>
      <groupId>com.huaweicloud.dws</groupId>
      <artifactId>dws-connector-flink_${scala.version}_${flink.version}</artifactId>
      <version>${version}</version>
  </dependency>

• Introduced in Flink SQL mode

  When using Flink SQL to implement dws-connector-flink, you need to place the dws-connector-flink package and its dependencies in the Flink class loading directory. In 1.0.3 and later versions, the packages with dependencies have been released to the Maven repository. You can download the packages from the repository.

  1. Select the package that matches the Flink environment.
     Figure 1 Flink package
     
  2. Switch to the software package details page.
     Figure 2 Flink package details page
     
  3. Select the required version.
     Figure 3 Selecting the version to be downloaded
     
  4. Select to view all files.
     Figure 4 Viewing all files
     
     

     • In the file list of the corresponding version, javadoc is the document, and source is the source code. Exclude these two file types. The package with dependencies is the largest JAR package. The file name extension may vary slightly depending on the version.
     • If the Flink version does not exist, use a version similar to the current version.
  5. Click to download files.