​Hi У меня есть кластер HDF с 3 экземплярами Nifi, которые запускают задания (Hive/Spark) в кластере HDP. Обычно nifi записывает всю информацию в разные репозитории, доступные на локальной машине. Мой вопрос: записывает ли nifi какие-либо...

Я публикую потоковые файлы из nifi в kafka, используя процессор publishKafka_0_10. При чтении данных из Kafka через код последовательность данных не сохраняется (сортируется по отметке времени). Мой набор данных выглядит так: метка времени, канал,...

Я очень часто использую процессор GenerateFlowFile , чтобы протестировать поведение другого процессора и понять поток. Но каждый раз я забываю изменить «Расписание запуска» по умолчанию, которое по умолчанию равно «0». И прежде чем я это осознаю,...

Я получаю некоторые числовые данные с помощью API из URL-адреса, и я ищу способ выполнить некоторые математические операции в apache nifi перед помещением данных в каталог файлов. Спасибо уже сейчас. Между прочим, я использую процессор InvokeHTTP...

Я использую процессор UpdateRecord в Nifi, где мне нужно получить значение из одного пути записи (/ amount), добавить к нему какое-то значение и поместить полученное значение в другой путь записи (/ result). Я не мог найти никакого способа сделать...

Использование Hortonworks HDP 3.0.1 и HDF Sandbox на рабочем столе Docker Я вошел в HDP и попытался скопировать файл из точки /user/maria_dev/tutorials/test.csv в HDF / sandbox / tutorial-files / 640 / nifi / input, НО это не работает. Как мне...