import org.apache.hadoop.io.serializer.SerializationTestUtil; //导入依赖的package包/类
@Test
public void testSpecific() throws Exception {
  AvroRecord before = new AvroRecord();
  before.intField = 5;
  AvroRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}
 

import org.apache.hadoop.io.serializer.SerializationTestUtil; //导入依赖的package包/类
@Test
public void testReflectPkg() throws Exception {
  Record before = new Record();
  before.x = 10;
  conf.set(AvroReflectSerialization.AVRO_REFLECT_PACKAGES, 
      before.getClass().getPackage().getName());
  Record after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}
 

import org.apache.hadoop.io.serializer.SerializationTestUtil; //导入依赖的package包/类
@Test
public void testReflectInnerClass() throws Exception {
  InnerRecord before = new InnerRecord();
  before.x = 10;
  conf.set(AvroReflectSerialization.AVRO_REFLECT_PACKAGES, 
      before.getClass().getPackage().getName());
  InnerRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}
 

import org.apache.hadoop.io.serializer.SerializationTestUtil; //导入依赖的package包/类
@Test
public void testReflect() throws Exception {
  RefSerializable before = new RefSerializable();
  before.x = 10;
  RefSerializable after = 
    SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}
 

import org.apache.hadoop.io.serializer.SerializationTestUtil; //导入依赖的package包/类
public void testReflectPkg() throws Exception {
  Record before = new Record();
  before.x = 10;
  conf.set(AvroReflectSerialization.AVRO_REFLECT_PACKAGES, 
      before.getClass().getPackage().getName());
  Record after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}
 

import org.apache.hadoop.io.serializer.SerializationTestUtil; //导入依赖的package包/类
public void testReflectInnerClass() throws Exception {
  InnerRecord before = new InnerRecord();
  before.x = 10;
  conf.set(AvroReflectSerialization.AVRO_REFLECT_PACKAGES, 
      before.getClass().getPackage().getName());
  InnerRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}
 

import org.apache.hadoop.io.serializer.SerializationTestUtil; //导入依赖的package包/类
public void testReflect() throws Exception {
  RefSerializable before = new RefSerializable();
  before.x = 10;
  RefSerializable after = 
    SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}
 

import org.apache.hadoop.io.serializer.SerializationTestUtil; //导入依赖的package包/类
public void testSpecific() throws Exception {
  AvroRecord before = new AvroRecord();
  before.intField = 5;
  AvroRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}