Nifi: como escrever processador personalizado

eu quero escreverprocessador nifi que pode ler o arquivo xml do diretório hdfs e, em seguida, extrair seus dados em atributos de arquivo de fluxo, também se houver um caso em que dois processadores nifi possam obter esse arquivo e ler dados ou gravar algo nelecomo posso bloquear arquivos para que de cada vez apenas um processador possa usá-lo? Você pode me recomendar algum artigo, exemplos de código ou alguns materiais relacionados que possam me ajudar. Ainda não escrevi nenhum processador personalizado.

questionAnswers(2)

yourAnswerToTheQuestion