Использование Apache Avro Reflect
Сериализация Avro пользуется популярностью среди пользователей Hadoop, но примеры так сложно найти.
Может ли кто-нибудь помочь мне с этим примером кода? Меня больше всего интересует использование API Reflect для чтения / записи в файлы и использования аннотаций Union и Null.
public class Reflect {
public class Packet {
int cost;
@Nullable TimeStamp stamp;
public Packet(int cost, TimeStamp stamp){
this.cost = cost;
this.stamp = stamp;
}
}
public class TimeStamp {
int hour = 0;
int second = 0;
public TimeStamp(int hour, int second){
this.hour = hour;
this.second = second;
}
}
public static void main(String[] args) throws IOException {
TimeStamp stamp;
Packet packet;
stamp = new TimeStamp(12, 34);
packet = new Packet(9, stamp);
write(file, packet);
packet = new Packet(8, null);
write(file, packet);
file.close();
// open file to read.
packet = read(file);
packet = read(file);
}
}