Java 类org.apache.hadoop.io.serializer.SerializationTestUtil 实例源码

@Test
public void testSpecific() throws Exception {
  AvroRecord before = new AvroRecord();
  before.intField = 5;
  AvroRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

@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);
}

@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);
}

@Test
public void testReflect() throws Exception {
  RefSerializable before = new RefSerializable();
  before.x = 10;
  RefSerializable after = 
    SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

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);
}

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);
}

public void testReflect() throws Exception {
  RefSerializable before = new RefSerializable();
  before.x = 10;
  RefSerializable after = 
    SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

@Test
public void testSpecific() throws Exception {
  AvroRecord before = new AvroRecord();
  before.intField = 5;
  AvroRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

@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);
}

@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);
}

@Test
public void testReflect() throws Exception {
  RefSerializable before = new RefSerializable();
  before.x = 10;
  RefSerializable after = 
    SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

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);
}

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);
}

public void testReflect() throws Exception {
  RefSerializable before = new RefSerializable();
  before.x = 10;
  RefSerializable after = 
    SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

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);
}

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);
}

public void testReflect() throws Exception {
  RefSerializable before = new RefSerializable();
  before.x = 10;
  RefSerializable after = 
    SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

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);
}

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);
}

public void testReflect() throws Exception {
  RefSerializable before = new RefSerializable();
  before.x = 10;
  RefSerializable after = 
    SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

@Test
public void testSpecific() throws Exception {
  AvroRecord before = new AvroRecord();
  before.intField = 5;
  AvroRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

@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);
}

@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);
}

@Test
public void testReflect() throws Exception {
  RefSerializable before = new RefSerializable();
  before.x = 10;
  RefSerializable after = 
    SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

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);
}

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);
}

public void testReflect() throws Exception {
  RefSerializable before = new RefSerializable();
  before.x = 10;
  RefSerializable after = 
    SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

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);
}

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);
}

public void testReflect() throws Exception {
  RefSerializable before = new RefSerializable();
  before.x = 10;
  RefSerializable after = 
    SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

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);
}

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);
}

public void testReflect() throws Exception {
  RefSerializable before = new RefSerializable();
  before.x = 10;
  RefSerializable after = 
    SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

public void testSpecific() throws Exception {
  AvroRecord before = new AvroRecord();
  before.intField = 5;
  AvroRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

public void testSpecific() throws Exception {
  AvroRecord before = new AvroRecord();
  before.intField = 5;
  AvroRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

public void testSpecific() throws Exception {
  AvroRecord before = new AvroRecord();
  before.intField = 5;
  AvroRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

public void testSpecific() throws Exception {
  AvroRecord before = new AvroRecord();
  before.intField = 5;
  AvroRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

public void testSpecific() throws Exception {
  AvroRecord before = new AvroRecord();
  before.intField = 5;
  AvroRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

public void testSpecific() throws Exception {
  AvroRecord before = new AvroRecord();
  before.intField = 5;
  AvroRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}

public void testSpecific() throws Exception {
  AvroRecord before = new AvroRecord();
  before.intField = 5;
  AvroRecord after = SerializationTestUtil.testSerialization(conf, before);
  assertEquals(before, after);
}