代码之家 › 专栏 › 技术社区 › pfnuesel

在GenerateTableFetch处理器中手动设置“组件状态”

apache-nifi ecmascript-6 javascript

pfnuesel · 技术社区 · 4 年前

var Scope = Java.type('org.apache.nifi.components.state.Scope');
var map = context.stateManager.getState(Scope.LOCAL).toMap();

但我没有找到可循环的地图。我不明白的是如何选择GenerateTableFetch处理器来设置状态。

0 回复 | 直到 4 年前

Bryan Bende 4 年前

StateManager只允许组件访问它自己的状态,而不是另一个组件的状态,否则任何组件都可能错误地更改另一个组件的状态。

在后台,使用组件的UUID存储状态。如果您在集群中,那么它将存储在ZooKeeper中,您可以使用ZK CLI在ZooKeeper中手动修改数据。如果您是独立的,那么它将存储在state/local的预写日志中,我不确定是否有一个好的方法来手动修改它。

另外,在将流迁移到新集群时,首选机制是使用nifi工具箱中的ZK state migrator:

推荐文章

venkata · 在Nifi中,FirstInfirstOutpriorizer和OldestFlowFileFirstPriorizer之间的区别是什么

7 年前

Sateesh Telaprolu · nifi是否支持将单个流文件传输到处理器中的多个关系?

7 年前

Arnab Biswas · Apache Nifi慢速群集问题

7 年前

Prabhu Bentick · Apache nifi和pentaho端口问题

7 年前

Atanu chatterjee · Nifi Spark集成,不使用Kafka和Pyspark

7 年前

Samuel Miller · 群集上的Nifi 1.5不受信任代理

7 年前

data_addict · 针对多个流文件的单一通知邮件Nifi

7 年前

MiamiBeach · 是否可以在WildFly上部署Apache Nifi?

7 年前

Gaurang Shah · NIFI查询数据库组织。阿帕奇。阿夫罗。SchemaParseException:COUNT(*)中的非法字符;

7 年前

watery · 如何通过MongoDB查询结果有条件地处理流文件?

7 年前