我正在尝试找出在 Flink 中向执行器添加一些文件的方法。就像 Spark 中的SparkContext.addFile()SparkFiles.get()一样，Flink 中是否有任何可能的 API？谢谢。
您可以查看文档。作为 Flink 入口点的 Scala API 文档 forExecutionEnvironment类有一个 registerCachedFile 方法。这可以从分布式存储(例如hdfs(加载文件，并使其可用于代码中的所有UDF。
这是指向文档中说明相同内容的页面的链接 眨眼文档链接 检查广播变量部分