public class org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment extends java.lang.Object implements org.apache.kafkaesqueesque.common.protocol.Message
{
private int partitionIndex;
private java.util.List replicas;
private java.util.List addingReplicas;
private java.util.List removingReplicas;
private java.util.List _unknownTaggedFields;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0;
public static final org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS;
public void <init>(org.apache.kafkaesqueesque.common.protocol.Readable, short)
{
short v;
org.apache.kafkaesqueesque.common.protocol.Readable v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.Readable;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: void read(org.apache.kafkaesqueesque.common.protocol.Readable,short)>(v, v);
return;
}
public void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct, short)
{
short v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct;
v := @parameter: short;
specialinvoke v.<java.lang.Object: void <init>()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: void fromStruct(org.apache.kafkaesqueesque.common.protocol.types.Struct,short)>(v, v);
return;
}
public void <init>()
{
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
java.util.ArrayList v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: int partitionIndex> = 0;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas> = v;
return;
}
public short lowestSupportedVersion()
{
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
return 0;
}
public short highestSupportedVersion()
{
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
return 0;
}
public void read(org.apache.kafkaesqueesque.common.protocol.Readable, short)
{
java.lang.Integer v, v, v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v, v;
java.util.ArrayList v, v, v;
short v;
org.apache.kafkaesqueesque.common.protocol.Readable v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
java.lang.RuntimeException v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.Readable;
v := @parameter: short;
if v <= 0 goto label;
v = new org.apache.kafkaesqueesque.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 OngoingPartitionReassignment");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: int partitionIndex> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field replicas 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 = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field addingReplicas 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 = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas> = v;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = v - 1;
if v >= 0 goto label;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("non-nullable field removingReplicas 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 = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readInt()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<java.util.ArrayList: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas> = v;
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List _unknownTaggedFields> = null;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = 0;
label:
if v >= v goto label;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: int readUnsignedVarint()>();
lookupswitch(v)
{
default: goto label;
};
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Readable: java.util.List readUnknownTaggedField(java.util.List,int,int)>(v, v, v);
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List _unknownTaggedFields> = v;
v = v + 1;
goto label;
label:
return;
}
public void write(org.apache.kafkaesqueesque.common.protocol.Writable, org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache, short)
{
boolean v, v, v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.Writable v;
org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter v;
short v;
int v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v;
org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v;
java.util.Iterator v, v, v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.Writable;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
if v <= 0 goto label;
v = new org.apache.kafkaesqueesque.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 OngoingPartitionReassignment");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: int partitionIndex>;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
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.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
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.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
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.<java.lang.Integer: int intValue()>();
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeInt(int)>(v);
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List _unknownTaggedFields>;
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter: org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter forFields(java.util.List)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter: int numFields()>();
v = 0 + v;
interfaceinvoke v.<org.apache.kafkaesqueesque.common.protocol.Writable: void writeUnsignedVarint(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.RawTaggedFieldWriter: void writeRawTags(org.apache.kafkaesqueesque.common.protocol.Writable,int)>(v, 2147483647);
return;
}
public void fromStruct(org.apache.kafkaesqueesque.common.protocol.types.Struct, short)
{
java.lang.Integer v;
boolean v, v;
java.util.Set v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v, v, v, v;
java.lang.Object[] v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
java.util.ArrayList v, v, v, v;
short v;
int v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v;
java.util.Iterator v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
java.lang.Object v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct;
v := @parameter: short;
if v <= 0 goto label;
v = new org.apache.kafkaesqueesque.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 OngoingPartitionReassignment");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List _unknownTaggedFields> = null;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object get(java.lang.String)>("_tagged_fields");
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer getInt(java.lang.String)>("partition_index");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: int partitionIndex> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("replicas");
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("adding_replicas");
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("removing_replicas");
v = new java.util.ArrayList;
v = lengthof v;
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
v = interfaceinvoke v.<java.util.NavigableMap: boolean isEmpty()>();
if v != 0 goto label;
v = new java.util.ArrayList;
v = interfaceinvoke v.<java.util.NavigableMap: int size()>();
specialinvoke v.<java.util.ArrayList: void <init>(int)>(v);
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List _unknownTaggedFields> = v;
v = interfaceinvoke v.<java.util.NavigableMap: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: 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.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return;
}
public org.apache.kafkaesqueesque.common.protocol.types.Struct toStruct(short)
{
java.lang.Integer v;
org.apache.kafkaesqueesque.common.protocol.types.Schema v;
boolean v, v, v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v, v, v, v, v, v;
java.lang.Integer[] v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Schema[] v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
short v;
int v, v, v, v, v, v, v, v, v, v;
java.lang.String v;
java.util.Iterator v, v, v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
java.util.TreeMap v;
java.lang.Object v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v := @parameter: short;
if v <= 0 goto label;
v = new org.apache.kafkaesqueesque.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 OngoingPartitionReassignment");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = new java.util.TreeMap;
specialinvoke v.<java.util.TreeMap: void <init>()>();
v = new org.apache.kafkaesqueesque.common.protocol.types.Struct;
v = <org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS>;
v = v[v];
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Schema)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: int partitionIndex>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("partition_index", v);
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (java.lang.Integer)[v];
v = 0;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
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[v] = v;
goto label;
label:
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("replicas", v);
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (java.lang.Integer)[v];
v = 0;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
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[v] = v;
goto label;
label:
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("adding_replicas", v);
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = newarray (java.lang.Integer)[v];
v = 0;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
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[v] = v;
goto label;
label:
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("removing_replicas", v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("_tagged_fields", v);
return v;
}
public int size(org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache, short)
{
boolean v;
org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException v;
java.util.List v, v, v, v, v, v, v, v, v;
short v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.String v;
org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache v;
java.util.Iterator v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.ObjectSerializationCache;
v := @parameter: short;
v = 0;
if v <= 0 goto label;
v = new org.apache.kafkaesqueesque.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 OngoingPartitionReassignment");
specialinvoke v.<org.apache.kafkaesqueesque.common.errors.UnsupportedVersionException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v * 4;
v = v + v;
v = 4 + v;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v * 4;
v = v + v;
v = v + v;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v + 1;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = 0 + v;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = v * 4;
v = v + v;
v = v + v;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List _unknownTaggedFields>;
if v == null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List _unknownTaggedFields>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 0 + v;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: 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.kafkaesqueesque.common.protocol.types.RawTaggedField: int tag()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.RawTaggedField: int size()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.RawTaggedField: int size()>();
v = v + v;
goto label;
label:
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.ByteUtils: int sizeOfUnsignedVarint(int)>(v);
v = v + v;
return v;
}
public boolean equals(java.lang.Object)
{
int v, v;
boolean v, v, v, v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
java.util.List v, v, v, v, v, v, v, v, v, v, v, v;
java.lang.Object v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v := @parameter: java.lang.Object;
v = v instanceof org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: int partitionIndex>;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: int partitionIndex>;
if v == v goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
if v == null goto label;
return 0;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
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()
{
int v, v, v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
java.util.List v, v, v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: int partitionIndex>;
v = 0 + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
v = 31 * v;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: int hashCode()>();
label:
v = v + v;
return v;
}
public java.lang.String toString()
{
java.util.Iterator v, v, v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
java.util.List v, v, v;
int v;
java.lang.String v, v, v, v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: int partitionIndex>;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.MessageUtil: java.lang.String deepToString(java.util.Iterator)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.MessageUtil: java.lang.String deepToString(java.util.Iterator)>(v);
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.MessageUtil: java.lang.String deepToString(java.util.Iterator)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int,java.lang.String,java.lang.String,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[])>("OngoingPartitionReassignment(partitionIndex=\u, replicas=\u, addingReplicas=\u, removingReplicas=\u)");
return v;
}
public int partitionIndex()
{
int v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: int partitionIndex>;
return v;
}
public java.util.List replicas()
{
java.util.List v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas>;
return v;
}
public java.util.List addingReplicas()
{
java.util.List v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas>;
return v;
}
public java.util.List removingReplicas()
{
java.util.List v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas>;
return v;
}
public java.util.List unknownTaggedFields()
{
java.util.List v, v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
java.util.ArrayList v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: 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.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List _unknownTaggedFields> = v;
label:
v = v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List _unknownTaggedFields>;
return v;
}
public org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment setPartitionIndex(int)
{
int v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v := @parameter: int;
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: int partitionIndex> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment setReplicas(java.util.List)
{
java.util.List v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v := @parameter: java.util.List;
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List replicas> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment setAddingReplicas(java.util.List)
{
java.util.List v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v := @parameter: java.util.List;
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List addingReplicas> = v;
return v;
}
public org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment setRemovingReplicas(java.util.List)
{
java.util.List v;
org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment v;
v := @this: org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment;
v := @parameter: java.util.List;
v.<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: java.util.List removingReplicas> = v;
return v;
}
static void <clinit>()
{
java.lang.Object[] v;
org.apache.kafkaesqueesque.common.protocol.types.Schema v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field[] v;
org.apache.kafkaesqueesque.common.protocol.types.Field$TaggedFieldsSection v;
org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Schema[] v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[5];
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("partition_index", v, "The index of the partition.");
v[0] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("replicas", v, "The current replica set.");
v[1] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("adding_replicas", v, "The set of replicas we are currently adding.");
v[2] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType INT32>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.CompactArrayOf: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Type)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("removing_replicas", v, "The set of replicas we are currently removing.");
v[3] = v;
v = newarray (java.lang.Object)[0];
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.types.Field$TaggedFieldsSection: org.apache.kafkaesqueesque.common.protocol.types.Field$TaggedFieldsSection of(java.lang.Object[])>(v);
v[4] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0> = v;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Schema)[1];
v = <org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: org.apache.kafkaesqueesque.common.protocol.types.Schema SCHEMA_0>;
v[0] = v;
<org.apache.kafkaesqueesque.common.message.ListPartitionReassignmentsResponseData$OngoingPartitionReassignment: org.apache.kafkaesqueesque.common.protocol.types.Schema[] SCHEMAS> = v;
return;
}
}