在Avro的文件

我有一个看起来像这样一些JSON数据存储空值：在Avro的文件

{ 
    "id": 1998983092, 
    "name": "Test Name 1", 
    "type": "search string", 
    "creationDate": "2017-06-06T13:49:15.091+0000", 
    "lastModificationDate": "2017-06-28T14:53:19.698+0000", 
    "lastModifiedUsername": "[email protected]", 
    "lockedQuery": false, 
    "lockedByUsername": null 
    }

我能够在lockedQuery空值添加到GenericRecord对象没有问题。

GenericRecord record = new GenericData.Record(schema); 
if(json.isNull("lockedQuery")){ 
    record.put("lockedQuery", null); 
}

但是，后来当我尝试将该GenericRecord对象写入avro文件时，我得到一个空指针异常。

File file = new File("~/test.arvo"); 
DatumWriter<GenericRecord> datumWriter = new GenericDatumWriter<>(schema); 
DataFileWriter<GenericRecord> dataFileWriter = new DataFileWriter<>(datumWriter); 
dataFileWriter.create(schema, file); 
for(GenericRecord record: masterList) { 
    dataFileWriter.append(record); // NULL POINTER HERE 
}

当我运行该代码时，出现以下异常。有关如何处理空值到Avro文件的任何提示非常感谢。提前致谢。

java.lang.NullPointerException: null of boolean in field lockedQuery of 
com.mydomain.test1.domain.MyAvroRecord 
Exception in thread "main" java.lang.RuntimeException: 
org.apache.avro.file.DataFileWriter$AppendWriteException: 
java.lang.NullPointerException: null of boolean in field lockedQuery of 
com.mydomain.test1.domain.MyAvroRecord 
at com.mydomain.avro.App.main(App.java:198) 
Caused by: org.apache.avro.file.DataFileWriter$AppendWriteException: 
java.lang.NullPointerException: null of boolean in field lockedQuery of 
com.mydomain.test1.domain.MyAvroRecord 
at org.apache.avro.file.DataFileWriter.append(DataFileWriter.java:308)

编辑：这里是MyAvroRecord

public class MyAvroRecord { 
    long id; 
    String name; 
    String type; 
    Date timestamp; 
    Date lastModifcationDate; 
    String lastModifiedUsername; 
    Boolean lockedQuery;

来源

2017-08-13 mba12

这可能会有助于“MyAvroRecord”的定义。我并不特别是Avro专家，但通常在Java中，您不能将'null'存储在'boolean'（小写）字段中，因为它是一个原语。如果你想在一个布尔值中存储一个空值，你必须使用'Boolean'（大写），它是一个Object，可以为空。 –

感谢您的建议。我从MyAvroRecord添加了成员定义。模式文件与类型匹配。我正在使用布尔值并切换到布尔对象，但仍然具有相同的空指针。当我将“false”作为默认值存储时，错误消失，但我仍然不能在基于对象的布尔值中使用null。 – mba12

为了能够设置的Avro场null你应该允许这架Avro架构，通过增加null作为可能的类型领域之一。就以实例来看看从文件的Avro：

{ 
    "type": "record", 
    "name": "MyRecord", 
    "fields" : [ 
    {"name": "userId", "type": "long"},    // mandatory field 
    {"name": "userName", "type": ["null", "string"]} // optional field 
    ] 
}

这里userName被声明为复合型这可能是要么null或string。这种定义允许将userName字段设置为空。由于对比userId只能包含长整型值，因此尝试将userId设置为空将导致NullPointerException。

来源

2017-08-13 16:51:57

在Avro的文件

回答

相关问题