Использование 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);
    }
}

Ответы на вопрос(1)

Ваш ответ на вопрос