public class org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata extends java.lang.Object
{
public final org.apache.kafkaesque.common.TopicPartition topicPartition;
public final org.apache.kafkaesque.common.protocol.Errors error;
public final java.util.Optional leaderId;
public final java.util.Optional leaderEpoch;
public final java.util.List replicaIds;
public final java.util.List inSyncReplicaIds;
public final java.util.List offlineReplicaIds;
public void <init>(org.apache.kafkaesque.common.protocol.Errors, org.apache.kafkaesque.common.TopicPartition, java.util.Optional, java.util.Optional, java.util.List, java.util.List, java.util.List)
{
org.apache.kafkaesque.common.protocol.Errors v;
org.apache.kafkaesque.common.TopicPartition v;
java.util.List v, v, v;
org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata v;
java.util.Optional v, v;
v := @this: org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata;
v := @parameter: org.apache.kafkaesque.common.protocol.Errors;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v := @parameter: java.util.Optional;
v := @parameter: java.util.Optional;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: org.apache.kafkaesque.common.protocol.Errors error> = v;
v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: org.apache.kafkaesque.common.TopicPartition topicPartition> = v;
v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.Optional leaderId> = v;
v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.Optional leaderEpoch> = v;
v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.List replicaIds> = v;
v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.List inSyncReplicaIds> = v;
v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.List offlineReplicaIds> = v;
return;
}
public int partition()
{
int v;
org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata v;
org.apache.kafkaesque.common.TopicPartition v;
v := @this: org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata;
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: org.apache.kafkaesque.common.TopicPartition topicPartition>;
v = virtualinvoke v.<org.apache.kafkaesque.common.TopicPartition: int partition()>();
return v;
}
public java.lang.String topic()
{
java.lang.String v;
org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata v;
org.apache.kafkaesque.common.TopicPartition v;
v := @this: org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata;
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: org.apache.kafkaesque.common.TopicPartition topicPartition>;
v = virtualinvoke v.<org.apache.kafkaesque.common.TopicPartition: java.lang.String topic()>();
return v;
}
public org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata withoutLeaderEpoch()
{
org.apache.kafkaesque.common.protocol.Errors v;
org.apache.kafkaesque.common.TopicPartition v;
java.util.List v, v, v;
org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata v, v;
java.util.Optional v, v;
v := @this: org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata;
v = new org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata;
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: org.apache.kafkaesque.common.protocol.Errors error>;
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: org.apache.kafkaesque.common.TopicPartition topicPartition>;
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.Optional leaderId>;
v = staticinvoke <java.util.Optional: java.util.Optional empty()>();
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.List replicaIds>;
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.List inSyncReplicaIds>;
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.List offlineReplicaIds>;
specialinvoke v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: void <init>(org.apache.kafkaesque.common.protocol.Errors,org.apache.kafkaesque.common.TopicPartition,java.util.Optional,java.util.Optional,java.util.List,java.util.List,java.util.List)>(v, v, v, v, v, v, v);
return v;
}
public java.lang.String toString()
{
org.apache.kafkaesque.common.protocol.Errors v;
org.apache.kafkaesque.common.TopicPartition v;
java.util.List v, v, v;
org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata v;
java.util.Optional v, v;
java.lang.String v, v, v, v;
v := @this: org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata;
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: org.apache.kafkaesque.common.protocol.Errors error>;
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: org.apache.kafkaesque.common.TopicPartition topicPartition>;
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.Optional leaderId>;
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.Optional leaderEpoch>;
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.List replicaIds>;
v = staticinvoke <org.apache.kafkaesque.common.utils.Utils: java.lang.String join(java.util.Collection,java.lang.String)>(v, ",");
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.List inSyncReplicaIds>;
v = staticinvoke <org.apache.kafkaesque.common.utils.Utils: java.lang.String join(java.util.Collection,java.lang.String)>(v, ",");
v = v.<org.apache.kafkaesque.common.requests.MetadataResponse$PartitionMetadata: java.util.List offlineReplicaIds>;
v = staticinvoke <org.apache.kafkaesque.common.utils.Utils: java.lang.String join(java.util.Collection,java.lang.String)>(v, ",");
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.kafkaesque.common.protocol.Errors,org.apache.kafkaesque.common.TopicPartition,java.util.Optional,java.util.Optional,java.lang.String,java.lang.String,java.lang.String)>(v, v, v, 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[])>("PartitionMetadata(, error=\u, partition=\u, leader=\u, leaderEpoch=\u, replicas=\u, isr=\u, offlineReplicas=\u)");
return v;
}
}