【11】Flink 之 DataSet API(五):Distributed Cache(分布式缓存)_getdistributedcache-CSDN博客

网站介绍:文章浏览阅读717次。1、Distributed Cache(分布式缓存)Flink提供了一个分布式缓存,类似于hadoop,可以使用户在并行函数中很方便的读取本地文件此缓存的工作机制如下:程序注册一个文件或者目录(本地或者远程文件系统,例如hdfs或者s3),通过ExecutionEnvironment注册缓存文件并为它起一个名称。当程序执行,Flink自动将文件或者目录复制到所有taskmanager节点的本..._getdistributedcache