public class oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization extends oadd.org.apache.hadoop.io.serializer.avro.AvroSerialization
{
public static final java.lang.String AVRO_REFLECT_PACKAGES;
private java.util.Set packages;
public void <init>()
{
oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization v;
v := @this: oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization;
specialinvoke v.<oadd.org.apache.hadoop.io.serializer.avro.AvroSerialization: void <init>()>();
return;
}
public synchronized boolean accept(java.lang.Class)
{
java.lang.Package v, v;
java.util.Set v, v;
java.lang.Class v, v;
java.lang.String v;
oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization v;
boolean v, v, v;
v := @this: oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization;
v := @parameter: java.lang.Class;
v = v.<oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization: java.util.Set packages>;
if v != null goto label;
specialinvoke v.<oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization: void getPackages()>();
label:
v = class "Loadd/org/apache/hadoop/io/serializer/avro/AvroReflectSerializable;";
v = virtualinvoke v.<java.lang.Class: boolean isAssignableFrom(java.lang.Class)>(v);
if v != 0 goto label;
v = virtualinvoke v.<java.lang.Class: java.lang.Package getPackage()>();
if v == null goto label;
v = v.<oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization: java.util.Set packages>;
v = virtualinvoke v.<java.lang.Class: java.lang.Package getPackage()>();
v = virtualinvoke v.<java.lang.Package: java.lang.String getName()>();
v = interfaceinvoke v.<java.util.Set: boolean contains(java.lang.Object)>(v);
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
private void getPackages()
{
java.util.Set v;
java.lang.String[] v;
java.util.HashSet v;
int v, v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v;
oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization v;
v := @this: oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization;
v = virtualinvoke v.<oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.conf.Configuration: java.lang.String[] getStrings(java.lang.String)>("avro.reflect.pkgs");
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v.<oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization: java.util.Set packages> = v;
if v == null goto label;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization: java.util.Set packages>;
v = virtualinvoke v.<java.lang.String: java.lang.String trim()>();
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
return;
}
public oadd.org.apache.avro.io.DatumReader getReader(java.lang.Class)
{
oadd.org.apache.avro.reflect.ReflectDatumReader v;
java.lang.Class v;
java.lang.RuntimeException v;
oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization v;
java.lang.Exception v;
v := @this: oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization;
v := @parameter: java.lang.Class;
label:
v = new oadd.org.apache.avro.reflect.ReflectDatumReader;
specialinvoke v.<oadd.org.apache.avro.reflect.ReflectDatumReader: void <init>(java.lang.Class)>(v);
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.lang.Exception from label to label with label;
}
public oadd.org.apache.avro.Schema getSchema(java.lang.Object)
{
oadd.org.apache.avro.Schema v;
java.lang.Class v;
java.lang.Object v;
oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization v;
oadd.org.apache.avro.reflect.ReflectData v;
v := @this: oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization;
v := @parameter: java.lang.Object;
v = staticinvoke <oadd.org.apache.avro.reflect.ReflectData: oadd.org.apache.avro.reflect.ReflectData get()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<oadd.org.apache.avro.reflect.ReflectData: oadd.org.apache.avro.Schema getSchema(java.lang.reflect.Type)>(v);
return v;
}
public oadd.org.apache.avro.io.DatumWriter getWriter(java.lang.Class)
{
java.lang.Class v;
oadd.org.apache.avro.reflect.ReflectDatumWriter v;
oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization v;
v := @this: oadd.org.apache.hadoop.io.serializer.avro.AvroReflectSerialization;
v := @parameter: java.lang.Class;
v = new oadd.org.apache.avro.reflect.ReflectDatumWriter;
specialinvoke v.<oadd.org.apache.avro.reflect.ReflectDatumWriter: void <init>()>();
return v;
}
}