Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package com.cerner.avro.test;
- import java.io.ByteArrayOutputStream;
- import java.io.File;
- import java.io.IOException;
- import java.lang.reflect.InvocationTargetException;
- import org.apache.avro.Schema;
- import org.apache.avro.generic.GenericData;
- import org.apache.avro.generic.GenericDatumReader;
- import org.apache.avro.generic.GenericDatumWriter;
- import org.apache.avro.generic.GenericRecord;
- import org.apache.avro.io.DatumReader;
- import org.apache.avro.io.Decoder;
- import org.apache.avro.io.DecoderFactory;
- import org.apache.avro.io.Encoder;
- import org.apache.avro.io.EncoderFactory;
- public class TestAvroPassivity {
- @SuppressWarnings({ "deprecation", "rawtypes", "unchecked" })
- public static void main(String[] args) {
- File schemaFile_10 = new File("schema_old");
- Schema schema_10 = Schema.parse(schemaFile_10);
- File schemaFile_11 = new File("schema_new");
- Schema schema_11 = Schema.parse(schemaFile_11);
- ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
- Encoder e = EncoderFactory.get().binaryEncoder(outputStream, null);
- GenericDatumWriter w = new GenericDatumWriter(schema_10);
- // Populate data with 1.0 data
- GenericRecord r = new GenericData.Record(schema_10);
- r.put("employeeId", "employeeId");
- r.put("personId", "personId");
- // Encode
- w.write(r, e);
- e.flush();
- byte[] encodedByteArray = outputStream.toByteArray();
- String encodedString = outputStream.toString();
- System.out.println("encodedString: " + encodedString);
- DatumReader<GenericRecord> reader = new GenericDatumReader<GenericRecord>(schema_11);
- Decoder decoder = DecoderFactory.get().binaryDecoder(encodedByteArray, null);
- GenericRecord result = reader.read(null, decoder);
- System.out.println(result.get("employeeId").toString());
- System.out.println(result.get("personId").toString());
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement