如何在 Java 中使用 AVRO 序列化日期

新手上路,请多包涵

我实际上正在尝试使用 Avro 序列化包含日期的对象,但反序列化的日期与预期值不匹配(使用 avro 1.7.2 和 1.7.1 测试)。这是我正在序列化的课程:

 import java.text.SimpleDateFormat;
import java.util.Date;

public class Dummy {
    private Date date;
    private SimpleDateFormat df = new SimpleDateFormat("dd/MM/yyyy hh:mm:ss.SSS");

    public Dummy() {
    }

    public void setDate(Date date) {
        this.date = date;
    }

    public Date getDate() {
        return date;
    }

    @Override
    public String toString() {
        return df.format(date);
    }
}

用于序列化/反序列化的代码:

 import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.util.Date;

import org.apache.avro.Schema;
import org.apache.avro.io.DatumReader;
import org.apache.avro.io.DatumWriter;
import org.apache.avro.io.Decoder;
import org.apache.avro.io.DecoderFactory;
import org.apache.avro.io.Encoder;
import org.apache.avro.io.EncoderFactory;
import org.apache.avro.reflect.ReflectData;
import org.apache.avro.reflect.ReflectDatumReader;
import org.apache.avro.reflect.ReflectDatumWriter;

public class AvroSerialization {

    public static void main(String[] args) {
        Dummy expected = new Dummy();
        expected.setDate(new Date());
        System.out.println("EXPECTED: " + expected);
        Schema schema = ReflectData.get().getSchema(Dummy.class);
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        Encoder encoder = EncoderFactory.get().binaryEncoder(baos, null);
        DatumWriter<Dummy> writer = new ReflectDatumWriter<Dummy>(schema);
        try {
            writer.write(expected, encoder);
            encoder.flush();
            Decoder decoder = DecoderFactory.get().binaryDecoder(baos.toByteArray(), null);
            DatumReader<Dummy> reader = new ReflectDatumReader<Dummy>(schema);
            Dummy actual = reader.read(null, decoder);
            System.out.println("ACTUAL: " + actual);
        } catch (IOException e) {
            System.err.println("IOException: " + e.getMessage());
        }
    }
}

和输出:

 EXPECTED: 06/11/2012 05:43:29.188
ACTUAL: 06/11/2012 05:43:29.387

它与已知错误有关,还是与我序列化对象的方式有关?

原文由 Miguel L. 发布,翻译遵循 CC BY-SA 4.0 许可协议

阅读 623
2 个回答

我认为 AVRO 此时不会序列化日期。我要做的是将它包装在另一个类中并存储在一个 long (date.gettime()) 中,而 avro 人员添加 此功能。您看到不同 Date 值的原因是每次您(和 avro)创建 Date 对象时,它都会使用当前系统时间初始化 Date。

原文由 amas 发布,翻译遵循 CC BY-SA 3.0 许可协议

Avro 1.8 现在有一个日期“logicalType”,它注释为 int。例如:

{“名称”:“日期”,“类型”:“整数”,“逻辑类型”:“日期”}

引用规范:“日期逻辑类型注释 Avro int,其中 int 存储从 unix 纪元 1970 年 1 月 1 日(ISO 日历)开始的天数。”

原文由 teu 发布,翻译遵循 CC BY-SA 3.0 许可协议

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题