Я пытаюсь запустить пример приложения локально, используя: Scala (2.11), Spark (2.3.0) с...
Я пытаюсь написать оценщик искры в Streamsets.Я имею дело со сложными запросами SQL и,...
У меня проблемы с запуском конвейера в наборах потоков, я вижу следующую ошибку: HADOOPFS_44 -...
Как удалить n строк сверху = 2 и снизу = 1, используя jython, который сохраняется в sample.txt. Мой...
Я получаю следующую ошибку при запуске oracle cdc, так как сегодня утром он работал нормально, но с...
Я создал контейнер с помощью Docker, и этот контейнер работает на локальном хосте.Все, что я хочу...
Я пытаюсь перенести таблицу Oracle на Cassandra, используя Streamsets. Поскольку в их документе...
Я использую многопользовательский потребитель в streamsets SDC.Каждый раз, когда я перезапускаю...
Прежде всего, я не совсем знаю, что является основным языком этого. Я следовал учебнику . Мой код...
Мне нужно выполнить группирование по отдельным значениям категории и подсчитать количество записей...
Я читал статьи, связанные с Kafka и StreamSets, и мое понимание было Кафка выступает посредником...
В моем приложении у меня есть несколько асинхронных (не в реальном времени) конвейерных потоков, в...
Я пытаюсь получить доступ к объекту AWS S3, используя boto3 из python. Я дал AWS учетные данные
Я использую источник HttpClient для потоковой передачи файла из URL-адреса HTTP в место назначения...
Я хотел зашифровать поле dob. Поэтому я пытаюсь использовать этап шифрования в streamsets. Я...
Я знаю, что Airflow называется менеджером потока операций, менеджером потока данных nifi, но что...
Я использую StreamSets в качестве инструмента для загрузки записей из базы данных Oracle в разделы...
Это для потоковых наборов, я пытаюсь написать отличный сценарий. У меня есть строка длиной 1500...
Я получаю следующую ошибку при подключении через клиент oracle cdc, и моя исходная база данных...
У меня есть файл .zip, и я хочу извлечь его с помощью Streamsets и поместить данные (.zip) в Kafka....
Я пытаюсь использовать шаги процессора JavaScript в StreamSets. Я определил некоторые значения...
Мы пытаемся построить конвейер для чтения данных из JDBC (Источник) и Hive Metastore (Назначение) в...
Я пытаюсь получить данные из API SDC, защищенного Kerberos.Сначала я публикую учетные данные на...
Я использую инструмент stremasets ETL для преобразования данных. После преобразования отправка...
Apache NiFi медленнее, чем StreamSets? Я создал конвейер, который получает данные из темы Кафки и...