flink hashmap
时间: 2023-12-01 13:02:25 浏览: 32
根据提供的引用内容,可以得知HashMapStateBackend是Flink中一种状态后端,它将状态存储在JVM堆内存中,因此在存取状态时速度很快。但是由于状态都放在内存中,如果状态超大可能会导致内存溢出,从而导致状态失败。相比之下,EmbeddedRocksDBStateBackend将状态存储在RocksDB数据库中,速度上比HashMapStateBackend慢一些,但存储容量更大,对容量几乎没有上面限制。
如果要使用HashMapStateBackend,可以按照以下步骤进行设置:
1.导入HashMapStateBackend类:
```java
import org.apache.flink.runtime.state.hashmap.HashMapStateBackend;
```
2.创建StreamExecutionEnvironment对象:
```java
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
```
3.将HashMapStateBackend作为状态后端设置到StreamExecutionEnvironment对象中:
```java
env.setStateBackend(new HashMapStateBackend());
```
如果要使用EmbeddedRocksDBStateBackend,可以按照以下步骤进行设置:
1.导入EmbeddedRocksDBStateBackend类:
```java
import org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend;
```
2.创建StreamExecutionEnvironment对象:
```java
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
```
3.将EmbeddedRocksDBStateBackend作为状态后端设置到StreamExecutionEnvironment对象中:
```java
env.setStateBackend(new EmbeddedRocksDBStateBackend());
```
相关推荐
![docx](https://img-home.csdnimg.cn/images/20210720083331.png)
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![pdf](https://img-home.csdnimg.cn/images/20210720083512.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)
![](https://csdnimg.cn/download_wenku/file_type_ask_c1.png)