Как передать файл, используя файл (исходный модуль), в hdfs-dataset(сток) в местоположение hdfs, используя Spring XD

Я использую ниже поток, чтобы выбрать файл из моего локального и поместить его в формате hdfs в формате avro. В соответствии с документацией SringXD я выполняю все шаги, а также использую команду, аналогичную той, которая есть в документации.

но проблема, с которой я столкнулся, была файлом данных avro или файлом схемы avro (avsc), не являются правильными. когда я открываю файл avsc, я вижу в нем только "строку". Я не знаю почему....

Может кто-нибудь проверить и помочь мне, что здесь не так, или Пожалуйста, помогите мне найти правильный подход к моему требованию.

поток создать - имя mydataset - определение "file --dir=/tmp/SpringXD --outputType=text/plain | hdfs-dataset --format=avro --fsUri=" --deploy

0 ответов

Другие вопросы по тегам