hadoop - NiFi 如何从 NiFi Flow 查询内容存储库
问题描述
我有一个用例，我需要从另一个流中使用 FlowFile。
据我所知，所有流文件都保存到内容存储库中。
因此，例如，我的第一个流程从 DB 读取数据，执行一些转换并放入 Hive。
我的第二个流程需要获取那些转换后的流程文件并将它们放到另一个地方或执行一些过滤等。
如何从 NiFi 流中的内容回购中获取这些流文件？
解决方案
你错了，流文件的内容保存在内容存储库中。您无需查询内容存储库即可使用这些流文件。我假设您正在使用PutHiveQL，因此只需将success关系用于下一个流。
示例：ExecuteSQL->(success) Transform Process Group->(output) PutHiveQL ->(success) -> Next Flow
像这样的东西：
推荐阅读
- apache-spark - 库存分析工具设计的设计理念
- epplus - EPPlus 图表不显示轴标签
- javascript - 尝试为我的 javascript 菜单添加第二个切换按钮
- python - 如何连接字典的键和值
- javascript - 在没有 CRA（create-react-app）的情况下从 react 到 express 获取错误
- python - Python中的非弹性碰撞
- vue.js - 离开站点时如何访问vuex商店
- java - 为什么在使用 OpenCSV 时出现“ClassNotFound”异常
- javascript - 笑话：模拟 navigator.storage.persist
- javascript - Firebase 存储“getDownloadURL”返回未定义