public class org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition extends java.lang.Object implements org.apache.kafkaesqueesqueesque.common.protocol.Message
{
private int partitionIndex;
private long partitionSize;
private long offsetLag;
private boolean isFutureKey;
private java.util.List _unknownTaggedFields;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_1;
public static final org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] SCHEMAS;
public void <init>(org.apache.kafkaesqueesqueesque.common.protocol.Readable, short)
{
org.apache.kafkaesqueesqueesque.common.protocol.Readable v;
short v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Readable;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: void read(org.apache.kafkaesqueesqueesque.common.protocol.Readable,short)>(v, v);
return;
}
public void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct, short)
{
org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v;
short v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: void fromStruct(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct,short)>(v, v);
return;
}
public void <init>()
{
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: int partitionIndex> = 0;
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long partitionSize> = 0L;
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long offsetLag> = 0L;
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: boolean isFutureKey> = 0;
return;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
return 1;
}
public void read(org.apache.kafkaesqueesqueesque.common.protocol.Readable, short)
{
org.apache.kafkaesqueesqueesque.common.protocol.Readable v;
long v, v;
org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v;
short v;
byte v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
int v;
java.lang.String v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Readable;
v := @parameter: short;
if v <= 1 goto label;
v = new org.apache.kafkaesqueesqueesque.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[])>("Can\'t read version \u of DescribeLogDirsPartition");
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: int partitionIndex> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: long readLong()>();
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long partitionSize> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: long readLong()>();
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long offsetLag> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Readable: byte readByte()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: boolean isFutureKey> = v;
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: java.util.List _unknownTaggedFields> = null;
return;
}
public void write(org.apache.kafkaesqueesqueesque.common.protocol.Writable, org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache, short)
{
long v, v;
org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v, v;
short v;
byte v;
int v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.Writable v;
java.lang.String v, v;
boolean v;
org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter v;
org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache v;
java.util.List v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.Writable;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
if v <= 1 goto label;
v = new org.apache.kafkaesqueesqueesque.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[])>("Can\'t write version \u of DescribeLogDirsPartition");
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: int partitionIndex>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long partitionSize>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeLong(long)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long offsetLag>;
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeLong(long)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: boolean isFutureKey>;
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
interfaceinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.Writable: void writeByte(byte)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: java.util.List _unknownTaggedFields>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter: org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter forFields(java.util.List)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedFieldWriter: int numFields()>();
v = 0 + v;
if v <= 0 goto label;
v = new org.apache.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void fromStruct(org.apache.kafkaesqueesqueesque.common.protocol.types.Struct, short)
{
long v, v;
org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v;
java.lang.Integer v;
short v;
java.lang.Long v, v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
int v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v;
java.lang.Boolean v;
java.lang.String v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct;
v := @parameter: short;
if v <= 1 goto label;
v = new org.apache.kafkaesqueesqueesque.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[])>("Can\'t read version \u of DescribeLogDirsPartition");
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: java.util.List _unknownTaggedFields> = null;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("partition_index");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: int partitionIndex> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Long getLong(java.lang.String)>("partition_size");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long partitionSize> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Long getLong(java.lang.String)>("offset_lag");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long offsetLag> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: java.lang.Boolean getBoolean(java.lang.String)>("is_future_key");
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: boolean isFutureKey> = v;
return;
}
public org.apache.kafkaesqueesqueesque.common.protocol.types.Struct toStruct(short)
{
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema v;
long v, v;
org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v;
java.lang.Integer v;
short v;
java.lang.Long v, v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
int v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Struct v;
java.lang.Boolean v;
java.lang.String v;
boolean v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v := @parameter: short;
if v <= 1 goto label;
v = new org.apache.kafkaesqueesqueesque.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[])>("Can\'t write version \u of DescribeLogDirsPartition");
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Struct;
v = <org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] SCHEMAS>;
v = v[v];
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Schema)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: int partitionIndex>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("partition_index", v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long partitionSize>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("partition_size", v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long offsetLag>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("offset_lag", v);
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: boolean isFutureKey>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("is_future_key", v);
return v;
}
public int size(org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache, short)
{
org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException v, v;
short v;
int v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v;
boolean v;
java.util.Iterator v;
org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache v;
java.util.List v, v, v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v := @parameter: org.apache.kafkaesqueesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = 0;
if v <= 1 goto label;
v = new org.apache.kafkaesqueesqueesque.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[])>("Can\'t size version \u of DescribeLogDirsPartition");
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = 21;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 0 + v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: 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.kafkaesqueesqueesque.common.protocol.types.RawTaggedField: int tag()>();
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedField: int size()>();
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.RawTaggedField: int size()>();
v = v + v;
goto label;
label:
if v <= 0 goto label;
v = new org.apache.kafkaesqueesqueesque.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.kafkaesqueesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public boolean equals(java.lang.Object)
{
long v, v, v, v;
byte v, v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
int v, v;
java.lang.Object v;
boolean v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: int partitionIndex>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: int partitionIndex>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long partitionSize>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long partitionSize>;
v = v cmp v;
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long offsetLag>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long offsetLag>;
v = v cmp v;
if v == 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: boolean isFutureKey>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: boolean isFutureKey>;
if v == v goto label;
return 0;
label:
return 1;
}
public int hashCode()
{
long v, v, v, v, v, v;
short v;
int v, v, v, v, v, v, v, v, v, v;
boolean v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: int partitionIndex>;
v = 0 + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long partitionSize>;
v = v >> 32;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long partitionSize>;
v = v ^ v;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long offsetLag>;
v = v >> 32;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long offsetLag>;
v = v ^ v;
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: boolean isFutureKey>;
if v == 0 goto label;
v = 1231;
goto label;
label:
v = 1237;
label:
v = v + v;
return v;
}
public java.lang.String toString()
{
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
int v;
long v, v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: int partitionIndex>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long partitionSize>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long offsetLag>;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: boolean isFutureKey>;
if v == 0 goto label;
v = "true";
goto label;
label:
v = "false";
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,long,long,java.lang.String)>(v, 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[])>("DescribeLogDirsPartition(partitionIndex=\u, partitionSize=\u, offsetLag=\u, isFutureKey=\u)");
return v;
}
public int partitionIndex()
{
int v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: int partitionIndex>;
return v;
}
public long partitionSize()
{
long v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long partitionSize>;
return v;
}
public long offsetLag()
{
long v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long offsetLag>;
return v;
}
public boolean isFutureKey()
{
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: boolean isFutureKey>;
return v;
}
public java.util.List unknownTaggedFields()
{
java.util.List v, v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: 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.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition setPartitionIndex(int)
{
int v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v := @parameter: int;
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: int partitionIndex> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition setPartitionSize(long)
{
long v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v := @parameter: long;
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long partitionSize> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition setOffsetLag(long)
{
long v;
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v := @parameter: long;
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: long offsetLag> = v;
return v;
}
public org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition setIsFutureKey(boolean)
{
org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition;
v := @parameter: boolean;
v.<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: boolean isFutureKey> = v;
return v;
}
static void <clinit>()
{
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Field[] v;
org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Field)[4];
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("partition_index", v, "The partition index.");
v[0] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("partition_size", v, "The size of the log segments in this partition in bytes.");
v[1] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType INT64>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("offset_lag", v, "The lag of the log\'s LEO w.r.t. partition\'s HW (if it is the current log for the partition) or current replica\'s LEO (if it is the future log for the partition)");
v[2] = v;
v = new org.apache.kafkaesqueesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesqueesque.common.protocol.types.Type$DocumentedType BOOLEAN>;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesqueesque.common.protocol.types.Type,java.lang.String)>("is_future_key", v, "True if this log is created by AlterReplicaLogDirsRequest and will replace the current log of the replica in the future.");
v[3] = v;
specialinvoke v.<org.apache.kafkaesqueesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0> = v;
v = <org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0>;
<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_1> = v;
v = newarray (org.apache.kafkaesqueesqueesque.common.protocol.types.Schema)[2];
v = <org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
v = <org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema SCHEMA_1>;
v[1] = v;
<org.apache.kafkaesqueesqueesque.common.message.DescribeLogDirsResponseData$DescribeLogDirsPartition: org.apache.kafkaesqueesqueesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}