flink-statebackend-redis 依赖
时间: 2023-08-05 10:02:52 浏览: 300
flink-statebackend-redis 是 Flink 提供的一个 StateBackend 插件,用于将 Flink 程序中的状态数据存储到 Redis 中。如果您想在 Flink 程序中使用 RedisStateBackend,需要在项目中引入 flink-statebackend-redis 依赖。
具体来说,在 Maven 项目中,您可以在 pom.xml 文件中添加以下依赖:
```
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-statebackend-redis</artifactId>
<version>${flink.version}</version>
</dependency>
```
在 Gradle 项目中,您可以在 build.gradle 文件中添加以下依赖:
```
dependencies {
implementation "org.apache.flink:flink-statebackend-redis:${flinkVersion}"
}
```
这里的 ${flink.version} 或 ${flinkVersion} 是指您使用的 Flink 版本号。如果您使用的是 Flink 1.12 及以上版本,可以直接使用 flink-statebackend-redis 依赖。如果您使用的是 Flink 1.11 及以下版本,需要先引入 flink-statebackend-rocksdb 依赖:
```
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-statebackend-rocksdb</artifactId>
<version>${flink.version}</version>
</dependency>
```
或者
```
dependencies {
implementation "org.apache.flink:flink-statebackend-rocksdb:${flinkVersion}"
}
```
然后再引入 flink-statebackend-redis 依赖:
```
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-statebackend-redis</artifactId>
<version>${flink.version}</version>
</dependency>
```
或者
```
dependencies {
implementation "org.apache.flink:flink-statebackend-redis:${flinkVersion}"
}
```
阅读全文