Импортировать данные из MongoDB в Hive - PullRequest
0 голосов
/ 09 июня 2019

Я пытаюсь импортировать документы из коллекции из MongoDB и создать таблицу в HIVE.

Вот запрос HIVE:

ADD JAR hdfs:///user/cloudera/mongo-java-driver-3.3.0.jar
ADD JAR hdfs:///user/cloudera/mongo-hadoop-core-2.0.2.jar
ADD JAR hdfs:///user/cloudera/mongo-hadoop-hive-2.0.2.jar
CREATE TABLE metadata_from_mongodb
(
    id INT,
    name STRING
)
STORED BY 'com.mongodb.hadoop.hive.MongoStorageHandler'
WITH SERDEPROPERTIES('mongo.columns.mapping'='{"id":"_id","name":"name"}')
TBLPROPERTIES('mongo.uri'='mongodb://localhost:27017/MyMongoDb.test');

Когда я запускаю этот запрос, он выводитследующая ошибка:

Error while processing statement: java.net.URISyntaxException: Illegal character in scheme name at index 15: SERDEPROPERTIES('mongo.columns.mapping'='{"id":"_id","name":"name"}')

Документ из коллекции выглядит следующим образом:

> db.test.find()
{ "_id" : 1, "name" : "Test" }

Не могли бы вы помочь мне прояснить этот вопрос?Я не смог найти какую-либо конкретную информацию для решения этой проблемы в Интернете.

Спасибо!

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...