我使用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);
}
您有什么更好的主意,我该如何改善?
这是图片:
最佳答案
您需要重写返回属性和关系的方法:
@Override
public Set<Relationship> getRelationships() {
return this.relationships;
}
@Override
protected List<PropertyDescriptor> getSupportedPropertyDescriptors() {
return this.properties;
}