Сохранение карты строки в список с помощью Gora в MongoDB - PullRequest
Новая
       65

Сохранение карты строки в список с помощью Gora в MongoDB

0 голосов
/ 18 июня 2020

Я пытаюсь сохранить POJO, содержащий карту строки для списка в MongoDB с использованием Gora. Я получаю исключение. 

java.lang.Exception: java.lang.RuntimeException: java.lang.IllegalStateException: Field ARRAY: To store a Gora 'array', target Mongo mapping have to be of 'list' type
    at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462)
    at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522)
Caused by: java.lang.RuntimeException: java.lang.IllegalStateException: Field ARRAY: To store a Gora 'array', target Mongo mapping have to be of 'list' type
    at org.apache.gora.mapreduce.GoraRecordWriter.write(GoraRecordWriter.java:76)
    at org.apache.hadoop.mapred.MapTask$NewDirectOutputCollector.write(MapTask.java:635)
    at org.apache.hadoop.mapreduce.task.TaskInputOutputContextImpl.write(TaskInputOutputContextImpl.java:89)
    at org.apache.hadoop.mapreduce.lib.map.WrappedMapper$Context.write(WrappedMapper.java:112)
    at org.apache.nutch.parse.ParserJob$ParserMapper.map(ParserJob.java:147)
    at org.apache.nutch.parse.ParserJob$ParserMapper.map(ParserJob.java:87)
    at org.apache.hadoop.mapreduce.Mapper.run(Mapper.java:145)
    at org.apache.hadoop.mapred.MapTask.runNewMapper(MapTask.java:764)
    at org.apache.hadoop.mapred.MapTask.run(MapTask.java:340)
    at org.apache.hadoop.mapred.LocalJobRunner$Job$MapTaskRunnable.run(LocalJobRunner.java:243)
    at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
    at java.util.concurrent.FutureTask.run(FutureTask.java:266)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
    at java.lang.Thread.run(Thread.java:748)
Caused by: java.lang.IllegalStateException: Field ARRAY: To store a Gora 'array', target Mongo mapping have to be of 'list' type
    at org.apache.gora.mongodb.store.MongoStore.toDBObject(MongoStore.java:747)
    at org.apache.gora.mongodb.store.MongoStore.mapToMongo(MongoStore.java:909)
    at org.apache.gora.mongodb.store.MongoStore.toDBObject(MongoStore.java:742)
    at org.apache.gora.mongodb.store.MongoStore.newUpdateSetInstance(MongoStore.java:689)
    at org.apache.gora.mongodb.store.MongoStore.performPut(MongoStore.java:349)
    at org.apache.gora.mongodb.store.MongoStore.put(MongoStore.java:326)
    at org.apache.gora.mongodb.store.MongoStore.put(MongoStore.java:70)
    at org.apache.gora.mapreduce.GoraRecordWriter.write(GoraRecordWriter.java:67)
    ... 14 more

Мой POJO выглядит следующим образом 

public class Host{
    Map<String, List<String>> outlinks;

    public Map<String, List<String>> getOutlinks() {
        return outlinks;
    }

    public void setOutlinks(Map<String, List<String>> outlinks) {
        this.outlinks = outlinks;
    }   
}

Я определил схему Avro следующим образом 

{
  "name": "Host",
  "type": "record",
  "namespace": "com.mypackage",
  "doc": "Some information",
  "fields": [
    {
      "name": "outlinks",
      "type": {
        "type": "map",
        "values":{
            "type":"array",
            "items":"string"
        }
      },
      "default": null
    }    
  ]
}

Я определил gora- mongodb-mapping. xml следующим образом 

<gora-otd>
    <class name="com.mypackage.Host" keyClass="java.lang.String" document="host">
        <field name="outlinks" docfield="outlinks" type="document"/>
    </class>
</gora-otd>

Я не могу понять, что мне здесь не хватает. Просит помочь пожалуйста. TIA

1 Ответ

0 голосов
/ 18 июня 2020

Я хочу предложить вам правильно хранить данные в mongoDB .. идеальный способ сохранить это, как ... вы также сможете искать по исходящей ссылке, используя простой запрос mongodb. вам не нужен этот xml файл .. 

public class Host{
     Strin key;
     List<String> outlinks;

    public void setKey(String key) {
        this.key = key;
    }
    public String getKey() {
        return key;
    }

    public void setOutlinks(List<String> outlinks) {
        this.outlinks = outlinks;
    }   
    public List<String> getOutlinks(){
        return outlinks;
   }

}
...