public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream extends java.io.InputStream implements java.io.ObjectInput
{
private final java.io.DataInputStream in;
private final int maxObjectSize;
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ClassResolver classResolver;
public void <init>(java.io.InputStream)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.InputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v := @parameter: java.io.InputStream;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: void <init>(java.io.InputStream,java.lang.ClassLoader)>(v, null);
return;
}
public void <init>(java.io.InputStream, java.lang.ClassLoader)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.lang.ClassLoader v;
java.io.InputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v := @parameter: java.io.InputStream;
v := @parameter: java.lang.ClassLoader;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: void <init>(java.io.InputStream,java.lang.ClassLoader,int)>(v, v, 1048576);
return;
}
public void <init>(java.io.InputStream, int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.InputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v := @parameter: java.io.InputStream;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: void <init>(java.io.InputStream,java.lang.ClassLoader,int)>(v, null, v);
return;
}
public void <init>(java.io.InputStream, java.lang.ClassLoader, int)
{
java.io.DataInputStream v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ClassResolver v;
java.lang.ClassLoader v;
boolean v;
java.io.InputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v := @parameter: java.io.InputStream;
v := @parameter: java.lang.ClassLoader;
v := @parameter: int;
specialinvoke v.<java.io.InputStream: void <init>()>();
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "in");
staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: int checkPositive(int,java.lang.String)>(v, "maxObjectSize");
v = v instanceof java.io.DataInputStream;
if v == 0 goto label;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in> = v;
goto label;
label:
v = new java.io.DataInputStream;
specialinvoke v.<java.io.DataInputStream: void <init>(java.io.InputStream)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in> = v;
label:
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ClassResolvers: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ClassResolver weakCachingResolver(java.lang.ClassLoader)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ClassResolver classResolver> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: int maxObjectSize> = v;
return;
}
public java.lang.Object readObject() throws java.lang.ClassNotFoundException, java.io.IOException
{
java.io.DataInputStream v;
java.io.StreamCorruptedException v, v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.CompactObjectInputStream v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ClassResolver v;
java.lang.String v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: int readInt()>();
if v > 0 goto label;
v = new java.io.StreamCorruptedException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("invalid data length: \u0001");
specialinvoke v.<java.io.StreamCorruptedException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: int maxObjectSize>;
if v <= v goto label;
v = new java.io.StreamCorruptedException;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: int maxObjectSize>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,int)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("data length too big: \u (max: \u)");
specialinvoke v.<java.io.StreamCorruptedException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.CompactObjectInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ClassResolver classResolver>;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.CompactObjectInputStream: void <init>(java.io.InputStream,org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ClassResolver)>(v, v);
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.CompactObjectInputStream: java.lang.Object readObject()>();
return v;
}
public int available() throws java.io.IOException
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: int available()>();
return v;
}
public void close() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
virtualinvoke v.<java.io.DataInputStream: void close()>();
return;
}
public void mark(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v := @parameter: int;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
virtualinvoke v.<java.io.DataInputStream: void mark(int)>(v);
return;
}
public boolean markSupported()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: boolean markSupported()>();
return v;
}
public int read() throws java.io.IOException
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: int read()>();
return v;
}
public final int read(byte[], int, int) throws java.io.IOException
{
byte[] v;
java.io.DataInputStream v;
int v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: int read(byte[],int,int)>(v, v, v);
return v;
}
public final int read(byte[]) throws java.io.IOException
{
byte[] v;
java.io.DataInputStream v;
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v := @parameter: byte[];
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: int read(byte[])>(v);
return v;
}
public final boolean readBoolean() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: boolean readBoolean()>();
return v;
}
public final byte readByte() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
byte v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: byte readByte()>();
return v;
}
public final char readChar() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
char v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: char readChar()>();
return v;
}
public final double readDouble() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
double v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: double readDouble()>();
return v;
}
public final float readFloat() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
float v;
java.io.DataInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: float readFloat()>();
return v;
}
public final void readFully(byte[], int, int) throws java.io.IOException
{
byte[] v;
java.io.DataInputStream v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
virtualinvoke v.<java.io.DataInputStream: void readFully(byte[],int,int)>(v, v, v);
return;
}
public final void readFully(byte[]) throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
byte[] v;
java.io.DataInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v := @parameter: byte[];
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
virtualinvoke v.<java.io.DataInputStream: void readFully(byte[])>(v);
return;
}
public final int readInt() throws java.io.IOException
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: int readInt()>();
return v;
}
public final java.lang.String readLine() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: java.lang.String readLine()>();
return v;
}
public final long readLong() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
long v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: long readLong()>();
return v;
}
public final short readShort() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
short v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: short readShort()>();
return v;
}
public final int readUnsignedByte() throws java.io.IOException
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: int readUnsignedByte()>();
return v;
}
public final int readUnsignedShort() throws java.io.IOException
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: int readUnsignedShort()>();
return v;
}
public final java.lang.String readUTF() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
java.lang.String v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: java.lang.String readUTF()>();
return v;
}
public void reset() throws java.io.IOException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
java.io.DataInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
virtualinvoke v.<java.io.DataInputStream: void reset()>();
return;
}
public long skip(long) throws java.io.IOException
{
java.io.DataInputStream v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
long v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v := @parameter: long;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: long skip(long)>(v);
return v;
}
public final int skipBytes(int) throws java.io.IOException
{
java.io.DataInputStream v;
int v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream;
v := @parameter: int;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.codec.serialization.ObjectDecoderInputStream: java.io.DataInputStream in>;
v = virtualinvoke v.<java.io.DataInputStream: int skipBytes(int)>(v);
return v;
}
}