public class org.apache.dubbo.common.serialize.avro.AvroObjectInput extends java.lang.Object implements org.apache.dubbo.common.serialize.ObjectInput
{
private static org.apache.avro.io.DecoderFactory decoderFactory;
private org.apache.avro.io.BinaryDecoder decoder;
public void <init>(java.io.InputStream)
{
org.apache.dubbo.common.serialize.avro.AvroObjectInput v;
org.apache.avro.io.BinaryDecoder v;
org.apache.avro.io.DecoderFactory v;
java.io.InputStream v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectInput;
v := @parameter: java.io.InputStream;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.DecoderFactory decoderFactory>;
v = virtualinvoke v.<org.apache.avro.io.DecoderFactory: org.apache.avro.io.BinaryDecoder binaryDecoder(java.io.InputStream,org.apache.avro.io.BinaryDecoder)>(v, null);
v.<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.BinaryDecoder decoder> = v;
return;
}
public boolean readBool() throws java.io.IOException
{
org.apache.avro.io.BinaryDecoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectInput v;
boolean v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectInput;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.BinaryDecoder decoder>;
v = virtualinvoke v.<org.apache.avro.io.BinaryDecoder: boolean readBoolean()>();
return v;
}
public byte readByte() throws java.io.IOException
{
byte[] v;
org.apache.dubbo.common.serialize.avro.AvroObjectInput v;
byte v;
org.apache.avro.io.BinaryDecoder v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectInput;
v = newarray (byte)[1];
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.BinaryDecoder decoder>;
virtualinvoke v.<org.apache.avro.io.BinaryDecoder: void readFixed(byte[])>(v);
v = v[0];
return v;
}
public short readShort() throws java.io.IOException
{
int v;
org.apache.avro.io.BinaryDecoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectInput v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectInput;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.BinaryDecoder decoder>;
v = virtualinvoke v.<org.apache.avro.io.BinaryDecoder: int readInt()>();
return v;
}
public int readInt() throws java.io.IOException
{
int v;
org.apache.avro.io.BinaryDecoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectInput v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectInput;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.BinaryDecoder decoder>;
v = virtualinvoke v.<org.apache.avro.io.BinaryDecoder: int readInt()>();
return v;
}
public long readLong() throws java.io.IOException
{
org.apache.avro.io.BinaryDecoder v;
long v;
org.apache.dubbo.common.serialize.avro.AvroObjectInput v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectInput;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.BinaryDecoder decoder>;
v = virtualinvoke v.<org.apache.avro.io.BinaryDecoder: long readLong()>();
return v;
}
public float readFloat() throws java.io.IOException
{
float v;
org.apache.avro.io.BinaryDecoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectInput v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectInput;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.BinaryDecoder decoder>;
v = virtualinvoke v.<org.apache.avro.io.BinaryDecoder: float readFloat()>();
return v;
}
public double readDouble() throws java.io.IOException
{
org.apache.avro.io.BinaryDecoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectInput v;
double v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectInput;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.BinaryDecoder decoder>;
v = virtualinvoke v.<org.apache.avro.io.BinaryDecoder: double readDouble()>();
return v;
}
public java.lang.String readUTF() throws java.io.IOException
{
org.apache.avro.util.Utf v, v;
org.apache.dubbo.common.serialize.avro.AvroObjectInput v;
org.apache.avro.io.BinaryDecoder v;
java.lang.String v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectInput;
v = new org.apache.avro.util.Utf;
specialinvoke v.<org.apache.avro.util.Utf8: void <init>()>();
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.BinaryDecoder decoder>;
v = virtualinvoke v.<org.apache.avro.io.BinaryDecoder: org.apache.avro.util.Utf readString(org.apache.avro.util.Utf)>(v);
v = virtualinvoke v.<org.apache.avro.util.Utf8: java.lang.String toString()>();
return v;
}
public byte[] readBytes() throws java.io.IOException
{
byte[] v;
org.apache.dubbo.common.serialize.avro.AvroObjectInput v;
java.nio.charset.Charset v;
org.apache.avro.io.BinaryDecoder v;
java.lang.String v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectInput;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.BinaryDecoder decoder>;
v = virtualinvoke v.<org.apache.avro.io.BinaryDecoder: java.lang.String readString()>();
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
return v;
}
public java.lang.Object readObject() throws java.io.IOException, java.lang.ClassNotFoundException
{
org.apache.dubbo.common.serialize.avro.AvroObjectInput v;
org.apache.avro.io.BinaryDecoder v;
java.lang.Object v;
org.apache.avro.reflect.ReflectDatumReader v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectInput;
v = new org.apache.avro.reflect.ReflectDatumReader;
specialinvoke v.<org.apache.avro.reflect.ReflectDatumReader: void <init>(java.lang.Class)>(class "Ljava/lang/Object;");
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.BinaryDecoder decoder>;
v = virtualinvoke v.<org.apache.avro.reflect.ReflectDatumReader: java.lang.Object read(java.lang.Object,org.apache.avro.io.Decoder)>(null, v);
return v;
}
public java.lang.Object readObject(java.lang.Class) throws java.io.IOException, java.lang.ClassNotFoundException
{
org.apache.dubbo.common.serialize.avro.AvroObjectInput v;
org.apache.avro.io.BinaryDecoder v;
java.lang.Class v;
java.lang.Object v;
org.apache.avro.reflect.ReflectDatumReader v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectInput;
v := @parameter: java.lang.Class;
if v != class "Ljava/util/Map;" goto label;
v = class "Ljava/util/HashMap;";
label:
v = new org.apache.avro.reflect.ReflectDatumReader;
specialinvoke v.<org.apache.avro.reflect.ReflectDatumReader: void <init>(java.lang.Class)>(v);
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.BinaryDecoder decoder>;
v = virtualinvoke v.<org.apache.avro.reflect.ReflectDatumReader: java.lang.Object read(java.lang.Object,org.apache.avro.io.Decoder)>(null, v);
return v;
}
public java.lang.Object readObject(java.lang.Class, java.lang.reflect.Type) throws java.io.IOException, java.lang.ClassNotFoundException
{
org.apache.dubbo.common.serialize.avro.AvroObjectInput v;
java.lang.reflect.Type v;
org.apache.avro.io.BinaryDecoder v;
java.lang.Class v;
java.lang.Object v;
org.apache.avro.reflect.ReflectDatumReader v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectInput;
v := @parameter: java.lang.Class;
v := @parameter: java.lang.reflect.Type;
v = new org.apache.avro.reflect.ReflectDatumReader;
specialinvoke v.<org.apache.avro.reflect.ReflectDatumReader: void <init>(java.lang.Class)>(v);
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.BinaryDecoder decoder>;
v = virtualinvoke v.<org.apache.avro.reflect.ReflectDatumReader: java.lang.Object read(java.lang.Object,org.apache.avro.io.Decoder)>(null, v);
return v;
}
static void <clinit>()
{
org.apache.avro.io.DecoderFactory v;
v = staticinvoke <org.apache.avro.io.DecoderFactory: org.apache.avro.io.DecoderFactory get()>();
<org.apache.dubbo.common.serialize.avro.AvroObjectInput: org.apache.avro.io.DecoderFactory decoderFactory> = v;
return;
}
}