public class org.apache.kafkaesque.common.message.UpdateMetadataRequestData extends java.lang.Object implements org.apache.kafkaesque.common.protocol.ApiMessage { private int controllerId; private int controllerEpoch; private long brokerEpoch; private java.util.List ungroupedPartitionStates; private java.util.List topicStates; private java.util.List liveBrokers; 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 SCHEMA_6; public static final org.apache.kafkaesque.common.protocol.types.Schema[] SCHEMAS; public void (org.apache.kafkaesque.common.protocol.Readable, short) { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; org.apache.kafkaesque.common.protocol.Readable v; short v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: org.apache.kafkaesque.common.protocol.Readable; v := @parameter: short; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void (org.apache.kafkaesque.common.protocol.types.Struct, short) { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; org.apache.kafkaesque.common.protocol.types.Struct v; short v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct; v := @parameter: short; specialinvoke v.()>(); virtualinvoke v.(v, v); return; } public void () { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; java.util.ArrayList v, v, v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; specialinvoke v.()>(); v. = 0; v. = 0; v. = -1L; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; return; } public short apiKey() { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; return 6; } public short lowestSupportedVersion() { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; return 0; } public short highestSupportedVersion() { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; return 6; } public void read(org.apache.kafkaesque.common.protocol.Readable, short) { org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; java.util.List v, v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; long v; java.util.ArrayList 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; org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataBroker v, v; java.lang.RuntimeException v, v, v, v, v; org.apache.kafkaesque.common.protocol.Readable v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataTopicState v, v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: org.apache.kafkaesque.common.protocol.Readable; v := @parameter: short; v = interfaceinvoke v.(); v. = v; v = interfaceinvoke v.(); v. = v; if v < 5 goto label; v = interfaceinvoke v.(); v. = v; goto label; label: v. = -1L; label: if v > 4 goto label; v = interfaceinvoke v.(); if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field ungroupedPartitionStates was serialized as null"); throw v; label: v = new java.util.ArrayList; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = new org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; specialinvoke v.(org.apache.kafkaesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; label: if v < 5 goto label; if v < 6 goto label; v = interfaceinvoke v.(); v = v - 1; if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field topicStates was serialized as null"); throw v; label: v = new java.util.ArrayList; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = new org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataTopicState; specialinvoke v.(org.apache.kafkaesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; goto label; label: v = interfaceinvoke v.(); if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field topicStates was serialized as null"); throw v; label: v = new java.util.ArrayList; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = new org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataTopicState; specialinvoke v.(org.apache.kafkaesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; label: if v < 6 goto label; v = interfaceinvoke v.(); v = v - 1; if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field liveBrokers was serialized as null"); throw v; label: v = new java.util.ArrayList; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = new org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataBroker; specialinvoke v.(org.apache.kafkaesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; goto label; label: v = interfaceinvoke v.(); if v >= 0 goto label; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String)>("non-nullable field liveBrokers was serialized as null"); throw v; label: v = new java.util.ArrayList; specialinvoke v.(int)>(v); v = 0; label: if v >= v goto label; v = new org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataBroker; specialinvoke v.(org.apache.kafkaesque.common.protocol.Readable,short)>(v, v); virtualinvoke v.(v); v = v + 1; goto label; label: v. = v; label: v. = null; if v < 6 goto label; v = interfaceinvoke v.(); v = 0; label: if v >= v goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); lookupswitch(v) { default: goto label; }; label: v = v.; v = interfaceinvoke v.(v, v, v); v. = v; v = v + 1; goto label; label: return; } public void write(org.apache.kafkaesque.common.protocol.Writable, org.apache.kafkaesque.common.protocol.ObjectSerializationCache, short) { boolean v, v, v, v, v, v, v; org.apache.kafkaesque.common.protocol.Writable v; java.util.List v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesque.common.protocol.ObjectSerializationCache v; org.apache.kafkaesque.common.protocol.types.RawTaggedFieldWriter v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; long v; short v; int v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v; java.util.Iterator v, v, v, v, v; org.apache.kafkaesque.common.errors.UnsupportedVersionException v, v, v; java.lang.Object v, v, v, v, v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: org.apache.kafkaesque.common.protocol.Writable; v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache; v := @parameter: short; v = v.; interfaceinvoke v.(v); v = v.; interfaceinvoke v.(v); if v < 5 goto label; v = v.; interfaceinvoke v.(v); label: if v > 4 goto label; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default ungroupedPartitionStates at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 5 goto label; if v < 6 goto label; v = v.; v = interfaceinvoke v.(); v = v + 1; interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default topicStates at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 6 goto label; v = v.; v = interfaceinvoke v.(); v = v + 1; interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = v.; v = staticinvoke (v); v = virtualinvoke v.(); v = 0 + v; if v < 6 goto label; interfaceinvoke v.(v); virtualinvoke v.(v, 2147483647); goto label; label: if v <= 0 goto label; v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Tagged fields were set, but version \u of this message does not support them."); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } public void fromStruct(org.apache.kafkaesque.common.protocol.types.Struct, short) { java.lang.Integer v, v; java.lang.Long v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState v; boolean v, v; java.util.Set v; java.util.List v, v, v, v; java.lang.Object[] v, v, v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; long v; java.util.ArrayList v, v, v, v, v, v; short v; int v, v, v, v, v, v, v, v, v, v, v, v; java.util.Iterator v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataBroker v; org.apache.kafkaesque.common.protocol.types.Struct v; java.lang.Object v, v, v, v, v, v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataTopicState v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: org.apache.kafkaesque.common.protocol.types.Struct; v := @parameter: short; v. = null; if v < 6 goto label; v = virtualinvoke v.("_tagged_fields"); label: v = virtualinvoke v.("controller_id"); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.("controller_epoch"); v = virtualinvoke v.(); v. = v; if v < 5 goto label; v = virtualinvoke v.("broker_epoch"); v = virtualinvoke v.(); v. = v; goto label; label: v. = -1L; label: if v > 4 goto label; v = virtualinvoke v.("ungrouped_partition_states"); v = new java.util.ArrayList; v = lengthof v; specialinvoke v.(int)>(v); v. = v; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; v = new org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataPartitionState; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v); interfaceinvoke v.(v); v = v + 1; goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; label: if v < 5 goto label; v = virtualinvoke v.("topic_states"); v = new java.util.ArrayList; v = lengthof v; specialinvoke v.(int)>(v); v. = v; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; v = new org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataTopicState; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v); interfaceinvoke v.(v); v = v + 1; goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; label: v = virtualinvoke v.("live_brokers"); v = new java.util.ArrayList; v = lengthof v; specialinvoke v.(int)>(v); v. = v; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v.; v = new org.apache.kafkaesque.common.message.UpdateMetadataRequestData$UpdateMetadataBroker; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Struct,short)>(v, v); interfaceinvoke v.(v); v = v + 1; goto label; label: if v < 6 goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = new java.util.ArrayList; v = interfaceinvoke v.(); specialinvoke v.(int)>(v); v. = v; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v); goto label; label: return; } public org.apache.kafkaesque.common.protocol.types.Struct toStruct(short) { java.lang.Integer v, v; org.apache.kafkaesque.common.protocol.types.Schema v; java.lang.Long v; boolean v, v, v, v, v; org.apache.kafkaesque.common.protocol.types.Schema[] v; java.util.List v, v, v, v, v, v, v, v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; long v; short v; int v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v; java.util.Iterator v, v, v; org.apache.kafkaesque.common.errors.UnsupportedVersionException v, v; org.apache.kafkaesque.common.protocol.types.Struct[] v, v, v; org.apache.kafkaesque.common.protocol.types.Struct v, v, v, v; java.util.TreeMap v, v; java.lang.Object v, v, v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: short; v = null; if v < 6 goto label; v = new java.util.TreeMap; specialinvoke v.()>(); v = v; label: v = new org.apache.kafkaesque.common.protocol.types.Struct; v = ; v = v[v]; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Schema)>(v); v = v.; v = staticinvoke (v); virtualinvoke v.("controller_id", v); v = v.; v = staticinvoke (v); virtualinvoke v.("controller_epoch", v); if v < 5 goto label; v = v.; v = staticinvoke (v); virtualinvoke v.("broker_epoch", v); label: if v > 4 goto label; v = v.; v = interfaceinvoke v.(); v = newarray (org.apache.kafkaesque.common.protocol.types.Struct)[v]; v = 0; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v; v = v + 1; v = virtualinvoke v.(v); v[v] = v; goto label; label: virtualinvoke v.("ungrouped_partition_states", v); goto label; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default ungroupedPartitionStates at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: if v < 5 goto label; v = v.; v = interfaceinvoke v.(); v = newarray (org.apache.kafkaesque.common.protocol.types.Struct)[v]; v = 0; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v; v = v + 1; v = virtualinvoke v.(v); v[v] = v; goto label; label: virtualinvoke v.("topic_states", v); goto label; label: v = v.; v = interfaceinvoke v.(); if v != 0 goto label; v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Attempted to write a non-default topicStates at version \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; v = interfaceinvoke v.(); v = newarray (org.apache.kafkaesque.common.protocol.types.Struct)[v]; v = 0; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v; v = v + 1; v = virtualinvoke v.(v); v[v] = v; goto label; label: virtualinvoke v.("live_brokers", v); if v < 6 goto label; virtualinvoke v.("_tagged_fields", v); label: return v; } public int size(org.apache.kafkaesque.common.protocol.ObjectSerializationCache, short) { boolean v, v, v, v; java.util.List v, v, v, v, v, v, v, v; org.apache.kafkaesque.common.protocol.ObjectSerializationCache v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData 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; java.lang.String v; java.util.Iterator v, v, v, v; org.apache.kafkaesque.common.errors.UnsupportedVersionException v; java.lang.Object v, v, v, v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: org.apache.kafkaesque.common.protocol.ObjectSerializationCache; v := @parameter: short; v = 0; v = 8; if v < 5 goto label; v = 16; label: if v > 4 goto label; v = 4; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v, v); v = v + v; goto label; label: v = v + v; label: if v < 5 goto label; if v < 6 goto label; v = v.; v = interfaceinvoke v.(); v = v + 1; v = staticinvoke (v); v = 0 + v; goto label; label: v = 4; label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v, v); v = v + v; goto label; label: v = v + v; label: if v < 6 goto label; v = v.; v = interfaceinvoke v.(); v = v + 1; v = staticinvoke (v); v = 0 + v; goto label; label: v = 4; label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v, v); v = v + v; goto label; label: v = v + v; v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); v = 0 + v; v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = v + v; v = virtualinvoke v.(); v = staticinvoke (v); v = v + v; v = virtualinvoke v.(); v = v + v; goto label; label: if v < 6 goto label; v = staticinvoke (v); v = v + v; goto label; label: if v <= 0 goto label; v = new org.apache.kafkaesque.common.errors.UnsupportedVersionException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Tagged fields were set, but version \u of this message does not support them."); specialinvoke v.(java.lang.String)>(v); throw v; label: return v; } public boolean equals(java.lang.Object) { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; long v, v; byte v; int v, v, v, v; boolean v, v, v, v; java.util.List v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Object v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: java.lang.Object; v = v instanceof org.apache.kafkaesque.common.message.UpdateMetadataRequestData; if v != 0 goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; v = v.; if v == v goto label; return 0; label: v = v.; v = v.; v = v cmp v; if v == 0 goto label; return 0; label: v = v.; if v != null goto label; v = v.; if v == null goto label; return 0; label: v = v.; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; return 0; label: v = v.; if v != null goto label; v = v.; if v == null goto label; return 0; label: v = v.; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; return 0; label: v = v.; if v != null goto label; v = v.; if v == null goto label; return 0; label: v = v.; v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; return 0; label: return 1; } public int hashCode() { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; long v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.List v, v, v, v, v, v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v = v.; v = 0 + v; v = 31 * v; v = v.; v = v + v; v = 31 * v; v = v.; v = v >> 32; v = v.; v = v ^ v; v = v + v; v = 31 * v; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = interfaceinvoke v.(); label: v = v + v; v = 31 * v; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = interfaceinvoke v.(); label: v = v + v; v = 31 * v; v = v.; if v != null goto label; v = 0; goto label; label: v = v.; v = interfaceinvoke v.(); label: v = v + v; return v; } public java.lang.String toString() { java.util.Iterator v, v, v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; long v; java.util.List v, v, v; int v, v; java.lang.String v, v, v, v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v = v.; v = v.; v = v.; v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); v = v.; v = interfaceinvoke v.(); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v, v, v, v, v) ("UpdateMetadataRequestData(controllerId=\u, controllerEpoch=\u, brokerEpoch=\u, ungroupedPartitionStates=\u, topicStates=\u, liveBrokers=\u)"); return v; } public int controllerId() { int v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v = v.; return v; } public int controllerEpoch() { int v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v = v.; return v; } public long brokerEpoch() { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; long v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v = v.; return v; } public java.util.List ungroupedPartitionStates() { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; java.util.List v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v = v.; return v; } public java.util.List topicStates() { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; java.util.List v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v = v.; return v; } public java.util.List liveBrokers() { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; java.util.List v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v = v.; return v; } public java.util.List unknownTaggedFields() { java.util.List v, v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; java.util.ArrayList v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v = v.; if v != null goto label; v = new java.util.ArrayList; specialinvoke v.(int)>(0); v. = v; label: v = v.; return v; } public org.apache.kafkaesque.common.message.UpdateMetadataRequestData setControllerId(int) { int v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesque.common.message.UpdateMetadataRequestData setControllerEpoch(int) { int v; org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: int; v. = v; return v; } public org.apache.kafkaesque.common.message.UpdateMetadataRequestData setBrokerEpoch(long) { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; long v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: long; v. = v; return v; } public org.apache.kafkaesque.common.message.UpdateMetadataRequestData setUngroupedPartitionStates(java.util.List) { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; java.util.List v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: java.util.List; v. = v; return v; } public org.apache.kafkaesque.common.message.UpdateMetadataRequestData setTopicStates(java.util.List) { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; java.util.List v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: java.util.List; v. = v; return v; } public org.apache.kafkaesque.common.message.UpdateMetadataRequestData setLiveBrokers(java.util.List) { org.apache.kafkaesque.common.message.UpdateMetadataRequestData v; java.util.List v; v := @this: org.apache.kafkaesque.common.message.UpdateMetadataRequestData; v := @parameter: java.util.List; v. = v; return v; } static void () { org.apache.kafkaesque.common.protocol.types.ArrayOf v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Object[] v; org.apache.kafkaesque.common.protocol.types.Type$DocumentedType v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.kafkaesque.common.protocol.types.CompactArrayOf v, v; org.apache.kafkaesque.common.protocol.types.Field 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; org.apache.kafkaesque.common.protocol.types.Schema 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; org.apache.kafkaesque.common.protocol.types.Schema[] v; org.apache.kafkaesque.common.protocol.types.Field$TaggedFieldsSection v; org.apache.kafkaesque.common.protocol.types.Field[] v, v, v, v, v, v, v; v = new org.apache.kafkaesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[4]; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("controller_id", v, "The controller id."); v[0] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("controller_epoch", v, "The controller epoch."); v[1] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("ungrouped_partition_states", v, "In older versions of this RPC, each partition that we would like to update."); v[2] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("live_brokers", v, ""); v[3] = v; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Field[])>(v); = v; v = new org.apache.kafkaesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[4]; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("controller_id", v, "The controller id."); v[0] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("controller_epoch", v, "The controller epoch."); v[1] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("ungrouped_partition_states", v, "In older versions of this RPC, each partition that we would like to update."); v[2] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("live_brokers", v, ""); v[3] = v; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Field[])>(v); = v; v = new org.apache.kafkaesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[4]; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("controller_id", v, "The controller id."); v[0] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("controller_epoch", v, "The controller epoch."); v[1] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("ungrouped_partition_states", v, "In older versions of this RPC, each partition that we would like to update."); v[2] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("live_brokers", v, ""); v[3] = v; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Field[])>(v); = v; v = new org.apache.kafkaesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[4]; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("controller_id", v, "The controller id."); v[0] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("controller_epoch", v, "The controller epoch."); v[1] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("ungrouped_partition_states", v, "In older versions of this RPC, each partition that we would like to update."); v[2] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("live_brokers", v, ""); v[3] = v; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Field[])>(v); = v; v = new org.apache.kafkaesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[4]; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("controller_id", v, "The controller id."); v[0] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("controller_epoch", v, "The controller epoch."); v[1] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("ungrouped_partition_states", v, "In older versions of this RPC, each partition that we would like to update."); v[2] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("live_brokers", v, ""); v[3] = v; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Field[])>(v); = v; v = new org.apache.kafkaesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[5]; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("controller_id", v, "The controller id."); v[0] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("controller_epoch", v, "The controller epoch."); v[1] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("broker_epoch", v, "The broker epoch."); v[2] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("topic_states", v, "In newer versions of this RPC, each topic that we would like to update."); v[3] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = new org.apache.kafkaesque.common.protocol.types.ArrayOf; v = ; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Type)>(v); specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("live_brokers", v, ""); v[4] = v; specialinvoke v.(org.apache.kafkaesque.common.protocol.types.Field[])>(v); = v; v = new org.apache.kafkaesque.common.protocol.types.Schema; v = newarray (org.apache.kafkaesque.common.protocol.types.Field)[6]; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.(java.lang.String,org.apache.kafkaesque.common.protocol.types.Type,java.lang.String)>("controller_id", v, "The controller id."); v[0] = v; v = new org.apache.kafkaesque.common.protocol.types.Field; v = ; specialinvoke v.