我已经知道如何编写自定义处理器(扩展org.apache.nifi.processor.AbstractProcessor)。我已经使用了这种技术,我很乐意创建自定义的org.apache.nifi.components.PropertyDescriptor & org.apache.nifi.processor.Relationship字段,以及重写onTrigger方法。此外,我知道如何设置构建、建立报表和创建我的.nar文件。
我还没有搞清楚的是,是否有一个合理的模式来扩展本地NiFi处理器。我希望扩展一个本机处理器,这样我就可以在新的Unit测试中使用我的扩展类(而不是其他类)。
至少,我想要做的就是扩展处理器并为它定义的特定PropertyDescriptor设置值。镀金可能会阻止用户(例如通过NiFi画布)更改此配置。
有人能提供任何指导或一些参考资料吗?
谢谢!
附加详细信息:我的具体目标是在本机JoltTransformJSON处理器中设置JOLT_SPEC的值。不过,我希望在这个特定的类和字段之外有一个设置PropertyDescriptor值的约定。
https://stackoverflow.com/questions/51283930
复制相似问题