我有一个用例，需要从另一个流使用flowfile。据我所知，所有流文件都保存到内容存储库中。例如，我的第一个流从db读取数据，执行一些转换并放入hive。我的第二个流需要得到那些转换后的流文件，并将它们放到另一个地方或执行一些过滤，等等。如何从nifi flow中的content repo获取这些流文件？
webghufk1#
您搞错了，流文件的内容被保存到内容存储库中。使用这些流文件不需要查询内容存储库。。我猜你在用 PutHiveQL ，所以就用 success 为你的下一个流的关系。例子： ExecuteSQL ->（成功） Transform Process Group ->（输出）puthiveql->（成功）->下一个流像这样：
PutHiveQL
success
ExecuteSQL
Transform Process Group
1条答案
按热度按时间webghufk1#
您搞错了，流文件的内容被保存到内容存储库中。使用这些流文件不需要查询内容存储库。。我猜你在用
PutHiveQL，所以就用success为你的下一个流的关系。例子：
ExecuteSQL->（成功）Transform Process Group->（输出）puthiveql->（成功）->下一个流像这样：