Я пытаюсь импортировать документы из коллекции из 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" }
Не могли бы вы помочь мне прояснить этот вопрос?Я не смог найти какую-либо конкретную информацию для решения этой проблемы в Интернете.
Спасибо!