public class org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse extends org.apache.kafkaesqueesque.common.requests.AbstractResponse
{
public static final long INVALID_OFFSET_LAG;
private static final java.lang.String LOG_DIRS_KEY_NAME;
private static final java.lang.String LOG_DIR_KEY_NAME;
private static final java.lang.String TOPICS_KEY_NAME;
private static final java.lang.String PARTITIONS_KEY_NAME;
private static final java.lang.String SIZE_KEY_NAME;
private static final java.lang.String OFFSET_LAG_KEY_NAME;
private static final java.lang.String IS_FUTURE_KEY_NAME;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema DESCRIBE_LOG_DIRS_RESPONSE_V0;
private static final org.apache.kafkaesqueesque.common.protocol.types.Schema DESCRIBE_LOG_DIRS_RESPONSE_V1;
private final int throttleTimeMs;
private final java.util.Map logDirInfos;
public static org.apache.kafkaesqueesque.common.protocol.types.Schema[] schemaVersions()
{
org.apache.kafkaesqueesque.common.protocol.types.Schema v, v;
org.apache.kafkaesqueesque.common.protocol.types.Schema[] v;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Schema)[2];
v = <org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema DESCRIBE_LOG_DIRS_RESPONSE_V0>;
v[0] = v;
v = <org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema DESCRIBE_LOG_DIRS_RESPONSE_V1>;
v[1] = v;
return v;
}
public void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct)
{
java.lang.Integer v, v;
java.lang.Long v, v;
java.lang.Short v;
java.util.Map v;
org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse$LogDirInfo v;
org.apache.kafkaesqueesque.common.protocol.Errors v;
boolean v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v;
java.lang.Object[] v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
java.util.HashMap v, v;
long v, v;
org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse$ReplicaInfo v;
org.apache.kafkaesqueesque.common.TopicPartition v;
short v;
int v, v, v, v, v, v, v, v;
java.lang.Boolean v;
org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse v;
java.lang.String v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Str v;
java.lang.Object v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v, v;
v := @this: org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse;
v := @parameter: org.apache.kafkaesqueesque.common.protocol.types.Struct;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.AbstractResponse: void <init>()>();
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int THROTTLE_TIME_MS>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer get(org.apache.kafkaesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: int throttleTimeMs> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: java.util.Map logDirInfos> = v;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("log_dirs");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int ERROR_CODE>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Short get(org.apache.kafkaesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Short: short shortValue()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.protocol.Errors: org.apache.kafkaesqueesque.common.protocol.Errors forCode(short)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.String getString(java.lang.String)>("log_dir");
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("topics");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.String get(org.apache.kafkaesqueesque.common.protocol.types.Field$Str)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Object[] getArray(java.lang.String)>("partitions");
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_ID>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Integer get(org.apache.kafkaesqueesque.common.protocol.types.Field$Int)>(v);
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Long getLong(java.lang.String)>("size");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Long getLong(java.lang.String)>("offset_lag");
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: java.lang.Boolean getBoolean(java.lang.String)>("is_future");
v = virtualinvoke v.<java.lang.Boolean: boolean booleanValue()>();
v = new org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse$ReplicaInfo;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse$ReplicaInfo: void <init>(long,long,boolean)>(v, v, v);
v = new org.apache.kafkaesqueesque.common.TopicPartition;
specialinvoke v.<org.apache.kafkaesqueesque.common.TopicPartition: void <init>(java.lang.String,int)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
v = v + 1;
goto label;
label:
v = v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: java.util.Map logDirInfos>;
v = new org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse$LogDirInfo;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse$LogDirInfo: void <init>(org.apache.kafkaesqueesque.common.protocol.Errors,java.util.Map)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
return;
}
public void <init>(int, java.util.Map)
{
int v;
org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse;
v := @parameter: int;
v := @parameter: java.util.Map;
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.AbstractResponse: void <init>()>();
v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: int throttleTimeMs> = v;
v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: java.util.Map logDirInfos> = v;
return;
}
protected org.apache.kafkaesqueesque.common.protocol.types.Struct toStruct(short)
{
org.apache.kafkaesqueesque.common.protocol.types.Schema v;
java.lang.Long v, v;
java.util.Map v, v, v;
org.apache.kafkaesqueesque.common.protocol.Errors v;
boolean v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.ApiKeys v;
java.util.Set v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v;
java.lang.Object[] v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v, v, v, v;
long v, v;
java.util.ArrayList v, v, v;
short v, v;
int v, v;
java.lang.Boolean v;
org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse v;
java.util.Iterator v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Str v;
java.lang.Object v, v, v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v, v;
v := @this: org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse;
v := @parameter: short;
v = new org.apache.kafkaesqueesque.common.protocol.types.Struct;
v = <org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.ApiKeys DESCRIBE_LOG_DIRS>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.types.Schema responseSchema(short)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Schema)>(v);
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int THROTTLE_TIME_MS>;
v = v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: int throttleTimeMs>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$Int,int)>(v, v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: java.util.Map logDirInfos>;
v = interfaceinvoke v.<java.util.Map: 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 = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct instance(java.lang.String)>("log_dirs");
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int ERROR_CODE>;
v = v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse$LogDirInfo: org.apache.kafkaesqueesque.common.protocol.Errors error>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.Errors: short code()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$Int,short)>(v, v);
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("log_dir", v);
v = v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse$LogDirInfo: java.util.Map replicaInfos>;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.CollectionUtils: java.util.Map groupPartitionDataByTopic(java.util.Map)>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Map: 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 = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct instance(java.lang.String)>("topics");
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$Str,java.lang.String)>(v, v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = interfaceinvoke v.<java.util.Map: 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 = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct instance(java.lang.String)>("partitions");
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_ID>;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(org.apache.kafkaesqueesque.common.protocol.types.Field$Int,int)>(v, v);
v = v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse$ReplicaInfo: long size>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("size", v);
v = v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse$ReplicaInfo: long offsetLag>;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("offset_lag", v);
v = v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse$ReplicaInfo: boolean isFuture>;
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("is_future", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("partitions", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("topics", v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray()>();
virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Struct: org.apache.kafkaesqueesque.common.protocol.types.Struct set(java.lang.String,java.lang.Object)>("log_dirs", v);
return v;
}
public int throttleTimeMs()
{
int v;
org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse v;
v := @this: org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse;
v = v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: int throttleTimeMs>;
return v;
}
public java.util.Map errorCounts()
{
java.util.Iterator v;
java.util.Collection v;
java.util.HashMap v;
java.util.Map v;
java.lang.Object v;
org.apache.kafkaesqueesque.common.protocol.Errors v;
org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse v;
boolean v;
v := @this: org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: java.util.Map logDirInfos>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: 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.requests.DescribeLogDirsResponse$LogDirInfo: org.apache.kafkaesqueesque.common.protocol.Errors error>;
virtualinvoke v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: void updateErrorCounts(java.util.Map,org.apache.kafkaesqueesque.common.protocol.Errors)>(v, v);
goto label;
label:
return v;
}
public java.util.Map logDirInfos()
{
org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse v;
java.util.Map v;
v := @this: org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse;
v = v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: java.util.Map logDirInfos>;
return v;
}
public static org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse parse(java.nio.ByteBuffer, short)
{
org.apache.kafkaesqueesque.common.protocol.ApiKeys v;
short v;
org.apache.kafkaesqueesque.common.protocol.types.Struct v;
org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse v;
java.nio.ByteBuffer v;
org.apache.kafkaesqueesque.common.protocol.types.Schema v;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: short;
v = new org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse;
v = <org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.ApiKeys DESCRIBE_LOG_DIRS>;
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.ApiKeys: org.apache.kafkaesqueesque.common.protocol.types.Schema responseSchema(short)>(v);
v = virtualinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: org.apache.kafkaesqueesque.common.protocol.types.Struct read(java.nio.ByteBuffer)>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Struct)>(v);
return v;
}
public boolean shouldClientThrottle(short)
{
org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse v;
short v;
boolean v;
v := @this: org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse;
v := @parameter: short;
if v < 1 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
static void <clinit>()
{
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v;
org.apache.kafkaesqueesque.common.protocol.types.Schema v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field[] v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Str v;
org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.ArrayOf v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field v, v, v, v, v, v, v;
org.apache.kafkaesqueesque.common.protocol.types.Field$Int v, v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int THROTTLE_TIME_MS>;
v[0] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[3];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int ERROR_CODE>;
v[0] = v;
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 STRING>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("log_dir", v, "The absolute log directory path.");
v[1] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[2];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Str TOPIC_NAME>;
v[0] = v;
v = new org.apache.kafkaesqueesque.common.protocol.types.Field;
v = new org.apache.kafkaesqueesque.common.protocol.types.ArrayOf;
v = new org.apache.kafkaesqueesque.common.protocol.types.Schema;
v = newarray (org.apache.kafkaesqueesque.common.protocol.types.Field)[4];
v = <org.apache.kafkaesqueesque.common.protocol.CommonFields: org.apache.kafkaesqueesque.common.protocol.types.Field$Int PARTITION_ID>;
v[0] = v;
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 INT64>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("size", v, "The size of the log segments of the partition in bytes.");
v[1] = v;
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 INT64>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.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.kafkaesqueesque.common.protocol.types.Field;
v = <org.apache.kafkaesqueesque.common.protocol.types.Type: org.apache.kafkaesqueesque.common.protocol.types.Type$DocumentedType BOOLEAN>;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Field: void <init>(java.lang.String,org.apache.kafkaesqueesque.common.protocol.types.Type,java.lang.String)>("is_future", 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.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.ArrayOf: 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)>("partitions", v);
v[1] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.ArrayOf: 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)>("topics", v);
v[2] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.ArrayOf: 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)>("log_dirs", v);
v[1] = v;
specialinvoke v.<org.apache.kafkaesqueesque.common.protocol.types.Schema: void <init>(org.apache.kafkaesqueesque.common.protocol.types.Field[])>(v);
<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema DESCRIBE_LOG_DIRS_RESPONSE_V0> = v;
v = <org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema DESCRIBE_LOG_DIRS_RESPONSE_V0>;
<org.apache.kafkaesqueesque.common.requests.DescribeLogDirsResponse: org.apache.kafkaesqueesque.common.protocol.types.Schema DESCRIBE_LOG_DIRS_RESPONSE_V1> = v;
return;
}
}