java - 尼菲 :Initialization in nifi custom processors

Question

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

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);
}

1. 您对如何改进它有更好的想法吗？这是图片:

Answer 1

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

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

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