# 引入依赖
#### 概述
dws-connector-flink是在dws-client的基础上对接Flink的一个工具，工具为对dws-client的包装，整体入库能力跟dws-client一致。dws-connector-flink为DWS团队自研工具，后续将根据DWS数据库持续优化。
![](https://support.huaweicloud.com/tg-dws/public_sys-resources/note_3.0-zh-cn.png)
dws-connector-flink的DWS-Connector只支持单并发查询存量数据，暂不支持并行读取。
#### 引入依赖下载地址
dws-connector-flink通过第三方maven仓库发布，可选择最新版本使用。
- **1.x版本** 不区分SQL和API，统一发布带依赖包，访问[下载地址](https://mvnrepository.com/artifact/com.huaweicloud.dws)获取，如[图1]显示的为1.x版本，根据对应scala、Flink版本进行选择。
  **软件包命名** **规则** 为：**dws-connector-flink_${scala.version}_${flink.version}**
  图11.x版本   
  ![](https://support.huaweicloud.com/tg-dws/figure/zh-cn_image_0000002490285126.png "点击放大") 

- **从2.x版本** 开始分为**带依赖** 和**不带依赖** 的版本。
  - **不带依赖的** **版本** ，仅可用于**Stream API场景** ，因为该软件包并不包含flink版本不兼容的API代码。
    统一使用dws-connector-flink命名，通过版本号区分不同环境，访问[下载地址](https://mvnrepository.com/artifact/com.huaweicloud.dws/dws-connector-flink)获取，如[图2]所示，根据对应scala、Flink版本进行选择。
    **软件包命名** **规则** 为：**${flink.version}_${scala.version}_${version}**
    图22.x不带依赖的版本   
    ![](https://support.huaweicloud.com/tg-dws/figure/zh-cn_image_0000002490128494.png "点击放大") 
  
  - **带依赖版本** ，支持**Flink SQL并兼容Stream API** **场景** ，访问[下载地址](https://mvnrepository.com/artifact/com.huaweicloud.dws)获取，如[图3]所示，先根据Flink版本选择对应包，再如[图4]所示，根据scala版本选择对应的最终包。
    **软件包命名规则** 为：**dws-connector-flink-sql-${flink.version}** ，内层版本规则为：${scala.version}_${version}，如：
    图32.x带依赖包的版本   
    ![](https://support.huaweicloud.com/tg-dws/figure/zh-cn_image_0000002522329923.png "点击放大")
    图4选择对应scala版本   
    ![](https://support.huaweicloud.com/tg-dws/figure/zh-cn_image_0000002522489381.png "点击放大")
    
    
   
 
#### jar包方式提交作业使用Maven方式引入
1.x版本
```
<dependency>
    <groupId>com.huaweicloud.dws</groupId>
    <artifactId>dws-connector-flink_${scala.version}_${flink.version}</artifactId>
    <version>${version}</version>
</dependency>
```
2.x flink sql场景
```
<dependency>
    <groupId>com.huaweicloud.dws</groupId>
    <artifactId>dws-connector-flink-sql-${flink.version}</artifactId>
    <version>${scala.version}_${version}</version>
</dependency>
```
2.x Stream API场景
```
<dependency>
    <groupId>com.huaweicloud.dws</groupId>
    <artifactId>dws-connector-flink</artifactId>
    <version>${flink.version}_${scala.version}_${version}</version>
</dependency>
```
#### 非jar包直接使用sql client或者第三方平台使用Flink SQL方式引入
在使用Flink SQL时需要将dws-connector-flink包及其依赖放入flink类加载目录，从1.0.3版本开始已经将带有依赖的包发布至maven仓库，使用时可直接在仓库下载使用：
1. 选择匹配flink环境的包。
   图5Flink包   
   ![](https://support.huaweicloud.com/tg-dws/figure/zh-cn_image_0000002159658012.png "点击放大") 
2. 进入软件包详情页面。
   图6Flink包详情页   
   ![](https://support.huaweicloud.com/tg-dws/figure/zh-cn_image_0000002159498652.png "点击放大") 
3. 选择最新版本。
   图7选择下载版本   
   ![](https://support.huaweicloud.com/tg-dws/figure/zh-cn_image_0000002194820133.png "点击放大") 
4. 单击对应文件即可下载。