public class org.apache.kafkaesque.common.message.ListOffsetRequestData extends java.lang.Object implements org.apache.kafkaesque.common.protocol.ApiMessage
{
private int replicaId;
private byte isolationLevel;
private java.util.List topics;
private java.util.List _unknownTaggedFields;
public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0;
public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1;
public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2;
public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_3;
public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_4;
public static final org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_5;
public static final org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS;
public void <init>(org.apache.kafkaesque.common.protocol.Readable, short)
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
org.apache.kafkaesque.common.protocol.Readable v;
short v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v := @parameter: org.apache.kafkaesque.common.protocol.Readable;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: void read(org.apache.kafkaesque.common.protocol.Readable,short)>(v, v);
return;
}
public void <init>(org.apache.kafkaesque.common.protocol.types.Struct, short)
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
org.apache.kafkaesque.common.protocol.types.Struct v;
short v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: void fromStruct(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
return;
}
public void <init>()
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: int replicaId> = 0;
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel> = 0;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics> = v;
return;
}
public short apiKey()
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
return 2;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
return 5;
}
public void read(org.apache.kafkaesque.common.protocol.Readable, short)
{
org.apache.kafkaesque.common.message.ListOffsetRequestData$ListOffsetTopic v;
java.lang.RuntimeException v;
java.util.ArrayList v;
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
short v;
byte v;
int v, v, v;
org.apache.kafkaesque.common.protocol.Readable v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v := @parameter: org.apache.kafkaesque.common.protocol.Readable;
v := @parameter: short;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: int replicaId> = v;
if v < 2 goto label;
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: byte readByte()>();
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel> = 0;
label:
v = interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Readable: int readInt()>();
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field topics was serialized as null");
throw v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v = 0;
label:
if v >= v goto label;
v = new org.apache.kafkaesque.common.message.ListOffsetRequestData$ListOffsetTopic;
specialinvoke v.<org.apache.kafkaesque.common.message.ListOffsetRequestData$ListOffsetTopic: void <init>(org.apache.kafkaesque.common.protocol.Readable,short)>(v, v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics> = v;
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List _unknownTaggedFields> = null;
return;
}
public void write(org.apache.kafkaesque.common.protocol.Writable, org.apache.kafkaesque.common.protocol.ObjectSerializationCache, short)
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
short v;
byte v, v;
int v, v, v, v;
java.lang.String v, v;
boolean v;
java.util.Iterator v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v, v;
org.apache.kafkaesque.common.protocol.Writable v;
java.util.List v, v, v;
java.lang.Object v;
org.apache.kafkaesque.common.protocol.ObjectSerializationCache v;
org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v := @parameter: org.apache.kafkaesque.common.protocol.Writable;
v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: int replicaId>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeInt(int)>(v);
if v < 2 goto label;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel>;
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeByte(byte)>(v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel>;
if v == 0 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Attempted to write a non-default isolationLevel at version \u0001");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: int size()>();
interfaceinvoke v.<org.apache.kafkaesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.kafkaesque.common.message.ListOffsetRequestData$ListOffsetTopic: void write(org.apache.kafkaesque.common.protocol.Writable,org.apache.kafkaesque.common.protocol.ObjectSerializationCache,short)>(v, v, v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List _unknownTaggedFields>;
v = staticinvoke <org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter: org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter forFields(java.util.List)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter: int numFields()>();
v = 0 + v;
if v <= 0 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Tagged fields were set, but version \u of this message does not support them.");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void fromStruct(org.apache.kafkaesque.common.protocol.types.Struct, short)
{
java.lang.Object[] v;
org.apache.kafkaesque.common.message.ListOffsetRequestData$ListOffsetTopic v;
java.lang.Integer v;
java.util.ArrayList v;
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
org.apache.kafkaesque.common.protocol.types.Struct v;
java.util.List v;
short v;
byte v;
int v, v, v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct;
v := @parameter: short;
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List _unknownTaggedFields> = null;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("replica_id");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: int replicaId> = v;
if v < 2 goto label;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: byte getByte(java.lang.String)>("isolation_level");
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel> = v;
goto label;
label:
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel> = 0;
label:
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("topics");
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
v = new org.apache.kafkaesque.common.message.ListOffsetRequestData$ListOffsetTopic;
specialinvoke v.<org.apache.kafkaesque.common.message.ListOffsetRequestData$ListOffsetTopic: void <init>(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
return;
}
public org.apache.kafkaesque.common.protocol.types.Struct toStruct(short)
{
java.lang.Integer v;
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
org.apache.kafkaesque.common.protocol.types.Schema v;
short v;
byte v, v;
int v, v, v, v;
java.lang.String v;
java.lang.Byte v;
boolean v;
java.util.Iterator v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v;
org.apache.kafkaesque.common.protocol.types.Schema[] v;
org.apache.kafkaesque.common.protocol.types.Struct[] v;
org.apache.kafkaesque.common.protocol.types.Struct v, v;
java.util.List v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v := @parameter: short;
v = new org.apache.kafkaesque.common.protocol.types.Struct;
v = <org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS>;
v = v[v];
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: void <init>(org.apache.kafkaesque.common.protocol.types.Schema)>(v);
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: int replicaId>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("replica_id", v);
if v < 2 goto label;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel>;
v = staticinvoke <java.lang.Byte: java.lang.Byte valueOf(byte)>(v);
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("isolation_level", v);
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel>;
if v == 0 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Attempted to write a non-default isolationLevel at version \u0001");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (org.apache.kafkaesque.common.protocol.types.Struct)[v];
v = 0;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = v;
v = v + 1;
v = virtualinvoke v.<org.apache.kafkaesque.common.message.ListOffsetRequestData$ListOffsetTopic: org.apache.kafkaesque.common.protocol.types.Struct toStruct(short)>(v);
v[v] = v;
goto label;
label:
virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.Struct: org.apache.kafkaesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("topics", v);
return v;
}
public int size(org.apache.kafkaesque.common.protocol.ObjectSerializationCache, short)
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
short v;
int v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v;
boolean v, v;
java.util.Iterator v, v;
org.apache.kafkaesque.common.errors.UnsupportedVersionException v;
java.util.List v, v, v, v;
java.lang.Object v, v;
org.apache.kafkaesque.common.protocol.ObjectSerializationCache v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = 0;
v = 4;
if v < 2 goto label;
v = 5;
label:
v = 4;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.message.ListOffsetRequestData$ListOffsetTopic: int size(org.apache.kafkaesque.common.protocol.ObjectSerializationCache,short)>(v, v);
v = v + v;
goto label;
label:
v = v + v;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 0 + v;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedField: int tag()>();
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedField: int size()>();
v = staticinvoke <org.apache.kafkaesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesque.common.protocol.types.RawTaggedField: int size()>();
v = v + v;
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (short)>(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[])>("Tagged fields were set, but version \u of this message does not support them.");
specialinvoke v.<org.apache.kafkaesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public boolean equals(java.lang.Object)
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
java.util.List v, v, v, v;
byte v, v;
int v, v;
java.lang.Object v;
boolean v, v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesque.common.message.ListOffsetRequestData;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: int replicaId>;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: int replicaId>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel>;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
if v != null goto label;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
return 1;
}
public int hashCode()
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
java.util.List v, v;
byte v;
int v, v, v, v, v, v, v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: int replicaId>;
v = 0 + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel>;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
return v;
}
public java.lang.String toString()
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
java.util.List v;
byte v;
java.util.Iterator v;
int v;
java.lang.String v, v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: int replicaId>;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel>;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesque.common.protocol.MessageUtil: java.lang.String deepToString(java.util.Iterator)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,byte,java.lang.String)>(v, 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[])>("ListOffsetRequestData(replicaId=\u, isolationLevel=\u, topics=\u)");
return v;
}
public int replicaId()
{
int v;
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: int replicaId>;
return v;
}
public byte isolationLevel()
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
byte v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel>;
return v;
}
public java.util.List topics()
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
java.util.List v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics>;
return v;
}
public java.util.List unknownTaggedFields()
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
java.util.List v, v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List _unknownTaggedFields>;
if v != null goto label;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(0);
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesque.common.message.ListOffsetRequestData setReplicaId(int)
{
int v;
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v := @parameter: int;
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: int replicaId> = v;
return v;
}
public org.apache.kafkaesque.common.message.ListOffsetRequestData setIsolationLevel(byte)
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
byte v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v := @parameter: byte;
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: byte isolationLevel> = v;
return v;
}
public org.apache.kafkaesque.common.message.ListOffsetRequestData setTopics(java.util.List)
{
org.apache.kafkaesque.common.message.ListOffsetRequestData v;
java.util.List v;
v := @this: org.apache.kafkaesque.common.message.ListOffsetRequestData;
v := @parameter: java.util.List;
v.<org.apache.kafkaesque.common.message.ListOffsetRequestData: java.util.List topics> = v;
return v;
}
static void <clinit>()
{
org.apache.kafkaesque.common.protocol.types.Field v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Schema v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Schema[] v;
org.apache.kafkaesque.common.protocol.types.ArrayOf v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Field[] v, v, v, v;
org.apache.kafkaesque.common.protocol.types.Type$DocumentedType v, v, v, v, v, v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("replica_id", v, "The broker ID of the requestor, or -1 if this request is being made by a normal consumer.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.message.ListOffsetRequestData$ListOffsetTopic: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("topics", v, "Each topic in the request.");
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[2];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("replica_id", v, "The broker ID of the requestor, or -1 if this request is being made by a normal consumer.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.message.ListOffsetRequestData$ListOffsetTopic: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("topics", v, "Each topic in the request.");
v[1] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[3];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("replica_id", v, "The broker ID of the requestor, or -1 if this request is being made by a normal consumer.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("isolation_level", v, "This setting controls the visibility of transactional records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records visible. With READ_COMMITTED (isolation_level = 1), non-transactional and COMMITTED transactional records are visible. To be more concrete, READ_COMMITTED returns all data from offsets smaller than the current LSO (last stable offset), and enables the inclusion of the list of aborted transactions in the result, which allows consumers to discard ABORTED transactional records");
v[1] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.message.ListOffsetRequestData$ListOffsetTopic: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("topics", v, "Each topic in the request.");
v[2] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2> = v;
v = <org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2>;
<org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_3> = v;
v = new org.apache.kafkaesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[3];
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("replica_id", v, "The broker ID of the requestor, or -1 if this request is being made by a normal consumer.");
v[0] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = <org.apache.kafkaesque.common.protocol.types.Type: org.apache.kafkaesque.common.protocol.types.Type$DocumentedType INT8>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("isolation_level", v, "This setting controls the visibility of transactional records. Using READ_UNCOMMITTED (isolation_level = 0) makes all records visible. With READ_COMMITTED (isolation_level = 1), non-transactional and COMMITTED transactional records are visible. To be more concrete, READ_COMMITTED returns all data from offsets smaller than the current LSO (last stable offset), and enables the inclusion of the list of aborted transactions in the result, which allows consumers to discard ABORTED transactional records");
v[1] = v;
v = new org.apache.kafkaesque.common.protocol.types.Field;
v = new org.apache.kafkaesque.common.protocol.types.ArrayOf;
v = <org.apache.kafkaesque.common.message.ListOffsetRequestData$ListOffsetTopic: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_4>;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.ArrayOf: void <init>(org.apache.kafkaesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("topics", v, "Each topic in the request.");
v[2] = v;
specialinvoke v.<org.apache.kafkaesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_4> = v;
v = <org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_4>;
<org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_5> = v;
v = newarray (org.apache.kafkaesque.common.protocol.types.Schema)[6];
v = <org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
v = <org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_1>;
v[1] = v;
v = <org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_2>;
v[2] = v;
v = <org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_3>;
v[3] = v;
v = <org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_4>;
v[4] = v;
v = <org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema SCHEMA_5>;
v[5] = v;
<org.apache.kafkaesque.common.message.ListOffsetRequestData: org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}