Pull to refresh

Comments 4

Такие процессоры упаковывают внешнюю информацию в FlowFile и отправляют на конвейерную ленту обработки

А разве upstream - не внешняя информация?

P.S. Кажется понял. Upstream это чисто внутреннее понятие. Но еще такой вопрос:

С одной стороны, очередь является выходом из процессора, или relation

А зачем в relation очередь если данные уничтожаются? Очередь на уничтожение?

Да в терминах NIFI у процессора есть Upstream Connection и Relation. Upstream Connection это вход для Процессора. И получается для Процессора это внешняя информация, но в рамках NIFI это входящая очередь данных внутри NIFI.

В процессоре строго определены возможные/используемые relation. Если какой то из Relation не нужен (то есть нам не интересно что в него направляется, и мы не планируем обрабатывать информацию попавшую в этот выход) то мы можем пометить данную очередь как "Terminated", в этом случае мы не обязаны куда то ее направлять, и данные попадающие в нее будут уничтожаться. Но тем не менее процессор все равно имеет эту выход, просто он никуда не ведет.

Минуточку, у меня все ходы записаны

А удаляются ящики, когда попадают на выход, который выключен. Такие выходы называются relations. 

То есть, вы прямо определяете закрытые выходы, где удаляются данные, как relations. Надо поправить.

Спасибо огромное, да логическая не стыковка в тексте вышла и я ее проглядел. Сейчас поправил должно стать понятнее. Любые выходы называются relations. И можно пометить Relation как Terminated

Sign up to leave a comment.