apache-nifi

1зной

2ответ

Взаимодействие с большой программой Java как услуга?

Как я могу сделать следующее? Что я хочу сделать, это загрузить Stanford NLP ONCE, а затем взаимодействовать с ним через HTTP или другую конечную точку. Причина в том, что загрузка занимает много врем

1зной

1ответ

NIFI - Передача не установлена

Я развернул простой поток данных: HandleHttpRequest - PutKafka - HandleHttpResponse. NIFI выбрасывает ошибку «передача отношения не указано», но не всегда. Может ли кто-нибудь помочь мне понять, почем

2зной

1ответ

Процессор ExecuteSQL в Apache Nifi

У меня возникла проблема при работе с Apache Nifi. Есть ли способ остановить ExecuteSQL-процессор после того, как он завершит выборку всех данных в таблице, а не выборки, пока я не остановлю ее вручну

2зной

2ответ

apache nifi полное время выполнения

Я хотел бы знать, как узнать/записать общее время выполнения для любого потока в Apache Nifi. Есть ли способ сделать это и добавить его в список атрибутов, чтобы одно и то же было передано через PutEm

5зной

1ответ

Как собирать сообщения бюллетеней в apache nifi

Я хочу знать, есть ли способ захватить сообщения бюллетеней (в основном ошибки), которые появляются в пользовательском интерфейсе Nifi, и хранить его в каком-либо атрибуте/файле, чтобы можно было смот

2зной

1ответ

Apache Nifi GetFTP-процессор Динамический ввод

Возможно передать динамические свойства, такие как ftp-хост, порт и т. Д. В процессор GetFTP. Я попробовал, но почему-то GetFTP-процессор не принимает никаких восходящих соединений. В основном я хочу

0зной

1ответ

Как получить групповой идентификатор процессора в apache nifi?

Еще один вопрос о Apache Nifi, как я могу получить идентификатор группы процессора, который также появляется при щелчке правой кнопкой мыши на процессоре, а затем нажмите на статистику? Есть ли способ

3зной

2ответ

Apache Nifi процессор, который действует как барьер для синхронизации нескольких файлов потока

Я оцениваю Nifi для нашего процесса ETL. Я хочу построить следующий поток: Извлечь много данных из базы данных SQL -> Разделить на куски 1000 записей каждый -> Количество записей об ошибках в каждом ф