public class org.apache.dubbo.common.serialize.avro.AvroObjectOutput extends java.lang.Object implements org.apache.dubbo.common.serialize.ObjectOutput
{
private static org.apache.avro.io.EncoderFactory encoderFactory;
private org.apache.avro.io.BinaryEncoder encoder;
public void <init>(java.io.OutputStream)
{
java.io.OutputStream v;
org.apache.avro.io.BinaryEncoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectOutput v;
org.apache.avro.io.EncoderFactory v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectOutput;
v := @parameter: java.io.OutputStream;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.EncoderFactory encoderFactory>;
v = virtualinvoke v.<org.apache.avro.io.EncoderFactory: org.apache.avro.io.BinaryEncoder binaryEncoder(java.io.OutputStream,org.apache.avro.io.BinaryEncoder)>(v, null);
v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder> = v;
return;
}
public void writeBool(boolean) throws java.io.IOException
{
org.apache.avro.io.BinaryEncoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectOutput v;
boolean v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectOutput;
v := @parameter: boolean;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder>;
virtualinvoke v.<org.apache.avro.io.BinaryEncoder: void writeBoolean(boolean)>(v);
return;
}
public void writeByte(byte) throws java.io.IOException
{
org.apache.avro.io.BinaryEncoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectOutput v;
byte[] v;
byte v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectOutput;
v := @parameter: byte;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder>;
v = newarray (byte)[1];
v[0] = v;
virtualinvoke v.<org.apache.avro.io.BinaryEncoder: void writeFixed(byte[])>(v);
return;
}
public void writeShort(short) throws java.io.IOException
{
org.apache.avro.io.BinaryEncoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectOutput v;
short v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectOutput;
v := @parameter: short;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder>;
virtualinvoke v.<org.apache.avro.io.BinaryEncoder: void writeInt(int)>(v);
return;
}
public void writeInt(int) throws java.io.IOException
{
int v;
org.apache.avro.io.BinaryEncoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectOutput v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectOutput;
v := @parameter: int;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder>;
virtualinvoke v.<org.apache.avro.io.BinaryEncoder: void writeInt(int)>(v);
return;
}
public void writeLong(long) throws java.io.IOException
{
org.apache.avro.io.BinaryEncoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectOutput v;
long v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectOutput;
v := @parameter: long;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder>;
virtualinvoke v.<org.apache.avro.io.BinaryEncoder: void writeLong(long)>(v);
return;
}
public void writeFloat(float) throws java.io.IOException
{
org.apache.avro.io.BinaryEncoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectOutput v;
float v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectOutput;
v := @parameter: float;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder>;
virtualinvoke v.<org.apache.avro.io.BinaryEncoder: void writeFloat(float)>(v);
return;
}
public void writeDouble(double) throws java.io.IOException
{
org.apache.avro.io.BinaryEncoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectOutput v;
double v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectOutput;
v := @parameter: double;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder>;
virtualinvoke v.<org.apache.avro.io.BinaryEncoder: void writeDouble(double)>(v);
return;
}
public void writeUTF(java.lang.String) throws java.io.IOException
{
org.apache.avro.io.BinaryEncoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectOutput v;
org.apache.avro.util.Utf v;
java.lang.String v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectOutput;
v := @parameter: java.lang.String;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder>;
v = new org.apache.avro.util.Utf;
specialinvoke v.<org.apache.avro.util.Utf8: void <init>(java.lang.String)>(v);
virtualinvoke v.<org.apache.avro.io.BinaryEncoder: void writeString(org.apache.avro.util.Utf)>(v);
return;
}
public void writeBytes(byte[]) throws java.io.IOException
{
org.apache.avro.io.BinaryEncoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectOutput v;
byte[] v;
java.nio.charset.Charset v;
java.lang.String v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectOutput;
v := @parameter: byte[];
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder>;
v = new java.lang.String;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
virtualinvoke v.<org.apache.avro.io.BinaryEncoder: void writeString(java.lang.String)>(v);
return;
}
public void writeBytes(byte[], int, int) throws java.io.IOException
{
org.apache.dubbo.common.serialize.avro.AvroObjectOutput v;
byte[] v, v;
org.apache.avro.io.BinaryEncoder v;
java.nio.charset.Charset v;
int v, v, v;
java.lang.String v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectOutput;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = v + v;
v = staticinvoke <java.util.Arrays: byte[] copyOfRange(byte[],int,int)>(v, v, v);
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder>;
v = new java.lang.String;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
virtualinvoke v.<org.apache.avro.io.BinaryEncoder: void writeString(java.lang.String)>(v);
return;
}
public void flushBuffer() throws java.io.IOException
{
org.apache.avro.io.BinaryEncoder v;
org.apache.dubbo.common.serialize.avro.AvroObjectOutput v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectOutput;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder>;
virtualinvoke v.<org.apache.avro.io.BinaryEncoder: void flush()>();
return;
}
public void writeObject(java.lang.Object) throws java.io.IOException
{
org.apache.avro.io.BinaryEncoder v, v;
org.apache.dubbo.common.serialize.avro.AvroObjectOutput v;
org.apache.avro.reflect.ReflectDatumWriter v;
java.lang.Class v;
java.lang.Object v;
v := @this: org.apache.dubbo.common.serialize.avro.AvroObjectOutput;
v := @parameter: java.lang.Object;
if v != null goto label;
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder>;
virtualinvoke v.<org.apache.avro.io.BinaryEncoder: void writeNull()>();
return;
label:
v = new org.apache.avro.reflect.ReflectDatumWriter;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
specialinvoke v.<org.apache.avro.reflect.ReflectDatumWriter: void <init>(java.lang.Class)>(v);
v = v.<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.BinaryEncoder encoder>;
virtualinvoke v.<org.apache.avro.reflect.ReflectDatumWriter: void write(java.lang.Object,org.apache.avro.io.Encoder)>(v, v);
return;
}
static void <clinit>()
{
org.apache.avro.io.EncoderFactory v;
v = staticinvoke <org.apache.avro.io.EncoderFactory: org.apache.avro.io.EncoderFactory get()>();
<org.apache.dubbo.common.serialize.avro.AvroObjectOutput: org.apache.avro.io.EncoderFactory encoderFactory> = v;
return;
}
}