Nifi - MergeContent - 多个 CSV 文件 - 计数器
Nifi - MergeContent - Multiple CSV files - counter
我想将 6 个 CSV 文件合并为 1 个
我用
ListHDFS >> FechHDFS >> UpdateAttribute >> MergeContent >> QueryRecord >> ...
ListHDFS >> FechHDFS >> UpdateAttribute 重复作为要合并的文件数（6 次）
因为我应该为每个文件提供 fragment.index 参数和别名（稍后用于 QueryRecord 中的连接查询）
其中一个文件的 UpdateAttribute：
有没有办法避免多个处理器获取文件 ListHDFS >> FechHDFS >> UpdateAttribute
如何将 is 缩减为一个 ListHDFS >> FechHDFS >> UpdateAttribute 并为每个不同的文件提供一个不同的 fragment.index 应该在 0 到 6（文件的最大数量）之间？
我试过 NextInt() 来赋予新的 fragment.index 值，但它是增量的，不适合多次执行。
提前致谢。
请在此线程中找到解决方案：
我想将 6 个 CSV 文件合并为 1 个
我用
ListHDFS >> FechHDFS >> UpdateAttribute >> MergeContent >> QueryRecord >> ...
ListHDFS >> FechHDFS >> UpdateAttribute 重复作为要合并的文件数（6 次）
因为我应该为每个文件提供 fragment.index 参数和别名（稍后用于 QueryRecord 中的连接查询）
其中一个文件的 UpdateAttribute：
有没有办法避免多个处理器获取文件 ListHDFS >> FechHDFS >> UpdateAttribute
如何将 is 缩减为一个 ListHDFS >> FechHDFS >> UpdateAttribute 并为每个不同的文件提供一个不同的 fragment.index 应该在 0 到 6（文件的最大数量）之间？
我试过 NextInt() 来赋予新的 fragment.index 值，但它是增量的，不适合多次执行。
提前致谢。
请在此线程中找到解决方案：