public final class org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata extends java.lang.Object
{
public static final int UNKNOWN_PARTITION;
private final long offset;
private final long timestamp;
private final int serializedKeySize;
private final int serializedValueSize;
private final org.apache.kafkaesqueesqueesque.common.TopicPartition topicPartition;
private volatile java.lang.Long checksum;
public void <init>(org.apache.kafkaesqueesqueesque.common.TopicPartition, long, long, long, java.lang.Long, int, int)
{
long v, v, v, v;
org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata v;
org.apache.kafkaesqueesqueesque.common.TopicPartition v;
byte v;
java.lang.Long v;
int v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata;
v := @parameter: org.apache.kafkaesqueesqueesque.common.TopicPartition;
v := @parameter: long;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.lang.Long;
v := @parameter: int;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v = v cmp -1L;
if v != 0 goto label;
v = v;
goto label;
label:
v = v + v;
label:
v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: long offset> = v;
v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: long timestamp> = v;
v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: java.lang.Long checksum> = v;
v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: int serializedKeySize> = v;
v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: int serializedValueSize> = v;
v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: org.apache.kafkaesqueesqueesque.common.TopicPartition topicPartition> = v;
return;
}
public boolean hasOffset()
{
byte v;
long v;
org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: long offset>;
v = v cmp -1L;
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public long offset()
{
long v;
org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: long offset>;
return v;
}
public boolean hasTimestamp()
{
byte v;
long v;
org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata v;
boolean v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: long timestamp>;
v = v cmp -1L;
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public long timestamp()
{
long v;
org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: long timestamp>;
return v;
}
public long checksum()
{
long v, v, v;
org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata v;
java.lang.Long v, v, v;
int v, v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: java.lang.Long checksum>;
if v != null goto label;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: long timestamp>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: int serializedKeySize>;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: int serializedValueSize>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.record.DefaultRecord: long computePartialChecksum(long,int,int)>(v, v, v);
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: java.lang.Long checksum> = v;
label:
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: java.lang.Long checksum>;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
return v;
}
public int serializedKeySize()
{
int v;
org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: int serializedKeySize>;
return v;
}
public int serializedValueSize()
{
int v;
org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: int serializedValueSize>;
return v;
}
public java.lang.String topic()
{
org.apache.kafkaesqueesqueesque.common.TopicPartition v;
java.lang.String v;
org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: org.apache.kafkaesqueesqueesque.common.TopicPartition topicPartition>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.TopicPartition: java.lang.String topic()>();
return v;
}
public int partition()
{
int v;
org.apache.kafkaesqueesqueesque.common.TopicPartition v;
org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: org.apache.kafkaesqueesqueesque.common.TopicPartition topicPartition>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.TopicPartition: int partition()>();
return v;
}
public java.lang.String toString()
{
org.apache.kafkaesqueesqueesque.common.TopicPartition v;
long v;
java.lang.String v, v;
org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata v;
v := @this: org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata;
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: org.apache.kafkaesqueesqueesque.common.TopicPartition topicPartition>;
v = virtualinvoke v.<org.apache.kafkaesqueesqueesque.common.TopicPartition: java.lang.String toString()>();
v = v.<org.apache.kafkaesqueesqueesque.clients.producer.RecordMetadata: long offset>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,long)>(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[])>("\u0001@\u0001");
return v;
}
}