个人中心
文章发布
退出
作者热门文章
- html - 出于某种原因，IE8 对我的 Sass 文件中继承的 html5 CSS 不友好？
- JMeter 在响应断言中使用 span 标签的问题
- html - 在 :hover and :active? 上具有不同效果的 CSS 动画
- html - 相对于居中的 html 内容固定的 CSS 重复背景？
30
4
这是关于Nifi中MergeContent处理器的问题。目前，我需要一次性将所有流文件与一个特定属性结合起来。
但是发生的事情是因为有太多的流文件具有相同的属性，处理器生成几个与属性合并的不同流文件，这些流文件应该一起组合成一个大流文件。
他们有什么方法可以等待所有具有相同属性的流文件进入 MergeContent 处理器并一次合并所有流文件吗？
如果不能，有什么替代方案？
最佳答案
您可以增加“最小条目数”和“最大条目数”以适合您的用例，并将“最大 Bin Age”增加到合适的时间。
您可以在此处引用合并内容的所有属性:https://nifi.apache.org/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.6.0/org.apache.nifi.processors.standard.MergeContent/index.html
此外，您是在集群中使用 nifi 还是单独使用？因为一个节点中的流文件不能与另一个节点中的流文件合并。
例如，如果您使用的 nifi 集群有 5 个节点，每个节点有 10 个流文件。使用合并内容处理器后，您将拥有 5 个文件。
如果您需要进一步的帮助，请告诉我!
关于merge - 尼菲 : Merging all of necessary flowfile in one shot with MergeContent Processor，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/56356164/
30
4
0
上周，我参加了几家大型 IT 公司的面试。一个让我有点困惑的问题。下面是问题的确切描述。(来自面试问题网站之一) 给定数据集， A,B,A,C,A,B,A,D,A,B,A,C,A,B,A,E,A,B,
我不知道什么是合适的术语，但“一次性”程序是指从主函数开始运行到结束并退出的程序。 通常我用这样的样板来做: AnnotationApplicationContext ac = new Annotat
我需要从静态 SKSpriteNode 向另一个动态节点发射“子弹”。我创建了一个镜头作为 Sprite 节点作为镜头，并通过 SKAction 将其移动到主 Sprite 节点，如下所示: let
function increase() { var counter = parseInt(document.getElementById("counter").innerHTML); counter-
我正在监控 python-twisted 框架中的 bool 值。当 bool 值改变时，我只想执行一次函数。这可以用 Python 完成吗？ 我正在从 IO 设备中串行提取 bool 值。在某个时间
我正在尝试找出我的应用程序在哪里放弃了内存以及我看到的所有资源都说标记了 heap shot。 但是我只有一个标记生成按钮。我应该在哪里找到堆射击按钮？或者它只是改变了。 抱歉，我是 iOS 新手。
我正在尝试实现类似Macs Selection屏幕截图的功能，我可以通过拖动光标来选择屏幕的一部分，并获取结果坐标(CGRect)。 所以像这样: 我一直在看 AVScreenShack，听起来它应该
我需要从不同的表多次查询 Azure 表存储，然后将所有结果合并到输出 HTTP 页面。 由于查询不相关，意味着没有特定的顺序，那么我可以将所有查询包装在一个 HTTP 请求中以节省查询时间吗？ 或者
我的输入: my $tmp = "rrccllrrc"; 预期输出: $tmp = "right right center center left left right right center";
我正在构建一个游戏，例如 Same Game ，当我必须创建一个新关卡时，我刚刚运行了一个算法来用 N 种颜色填充板子，这个算法随机填充板子，但显然以这种方式生成的关卡并不是都有解决方案。 我必须做一
我正在尝试使用 messages 参数而不是 prompt 参数来训练带有少量提示的 GPT 3.5 模型。尽管 OpenAI 文档中明确提到我们可以通过这种方式训练模型，但它还是会抛出错误。 imp
我正在尝试使用 messages 参数而不是 prompt 参数来训练带有少量提示的 GPT 3.5 模型。尽管 OpenAI 文档中明确提到我们可以通过这种方式训练模型，但它还是会抛出错误。 imp
我使用 SurfaceView 构建了一个简单的游戏引擎。 我将 RectF 用作“相机”窗口，以表示 SurfaceView Canvas 的缩放像素宽度和高度，并找出屏幕上的内容。 我使用 can
我正在尝试在 linux rhel5、内核 2.6.18、glibc 2.5-18 中使用 iNotify。我没有将事件定义为一次拍摄，但出于某种原因，它的行为就像我所做的那样。影响是我必须在每次事件
这是关于Nifi中MergeContent处理器的问题。目前，我需要一次性将所有流文件与一个特定属性结合起来。 但是发生的事情是因为有太多的流文件具有相同的属性，处理器生成几个与属性合并的不同流文件，
我正在挖掘Tensorflow Object Detection API为了检查 SSD architecture 的 anchor 框生成.在此 py file动态生成 anchor 框的地方，我无
我正在使用 npm react-native-view-shot捕获图像中的 View 并本地保存在设备上。 当我尝试使用以下代码拍摄快照时，我得到路径但不是该位置的图像，下面是代码和输出 路径:-
为什么 map 在调用一个可以迭代多次的对象时不返回一个也可以迭代多次的对象？我认为后者更为合理。 我的用例是我有很多数据，因此只能对其进行迭代。 map(理论上)非常适合对data 进行操作，因为它
关闭。这个问题是opinion-based .它目前不接受答案。 想要改进这个问题？ 更新问题，以便 editing this post 可以用事实和引用来回答它. 关闭 8 年前。 Improve
我正在使用带有 Okhttp 拦截器的 Retrofit 来检测我的 oauth token 是否已过期。如果 token 已过期，我想请求一个新 token ，再次尝试请求，然后将该响应发送给 Re
我是一名优秀的程序员,十分优秀！