我使用nifi 1.3.0,我添加了一个属性描述符目录和2个关系(失败和成功),但是由于某些原因,当我构建此程序并在nifi lib目录中导出nar失败后,处理了nifi并放置了MyProcessor之后,我得到的处理器没有财产和关系。这是我的代码和相关处理器图片:

protected void init(final ProcessorInitializationContext context) {
final List<PropertyDescriptor> properties = new ArrayList<>();
properties.add(DIRECTORY);

this.properties = Collections.unmodifiableList(properties);

final Set<Relationship> relationships = new HashSet<>();
relationships.add(REL_SUCCESS);
relationships.add(REL_FAILURE);
this.relationships = Collections.unmodifiableSet(relationships);
}



您有什么更好的主意,我该如何改善?
这是图片:
java - Nifi:nifi自定义处理器中的初始化-LMLPHP

最佳答案

您需要重写返回属性和关系的方法:

@Override
public Set<Relationship> getRelationships() {
  return this.relationships;
}

@Override
protected List<PropertyDescriptor> getSupportedPropertyDescriptors() {
  return this.properties;
}

09-12 00:49