public class org.apache.kafkaesque.clients.consumer.ConsumerRecords extends java.lang.Object implements java.lang.Iterable
{
public static final org.apache.kafkaesque.clients.consumer.ConsumerRecords EMPTY;
private final java.util.Map records;
public void <init>(java.util.Map)
{
org.apache.kafkaesque.clients.consumer.ConsumerRecords v;
java.util.Map v;
v := @this: org.apache.kafkaesque.clients.consumer.ConsumerRecords;
v := @parameter: java.util.Map;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesque.clients.consumer.ConsumerRecords: java.util.Map records> = v;
return;
}
public java.util.List records(org.apache.kafkaesque.common.TopicPartition)
{
java.util.List v, v;
org.apache.kafkaesque.clients.consumer.ConsumerRecords v;
org.apache.kafkaesque.common.TopicPartition v;
java.util.Map v;
java.lang.Object v;
v := @this: org.apache.kafkaesque.clients.consumer.ConsumerRecords;
v := @parameter: org.apache.kafkaesque.common.TopicPartition;
v = v.<org.apache.kafkaesque.clients.consumer.ConsumerRecords: java.util.Map records>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
return v;
label:
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
return v;
}
public java.lang.Iterable records(java.lang.String)
{
java.util.Iterator v;
java.util.Set v;
java.lang.IllegalArgumentException v;
java.util.ArrayList v;
org.apache.kafkaesque.clients.consumer.ConsumerRecords v;
java.util.Map v;
java.lang.Object v, v, v;
java.lang.String v, v;
org.apache.kafkaesque.clients.consumer.ConsumerRecords$ConcatenatedIterable v;
boolean v, v;
v := @this: org.apache.kafkaesque.clients.consumer.ConsumerRecords;
v := @parameter: java.lang.String;
if v != null goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("Topic must be non-null.");
throw v;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.apache.kafkaesque.clients.consumer.ConsumerRecords: java.util.Map records>;
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 getKey()>();
v = virtualinvoke v.<org.apache.kafkaesque.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
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:
v = new org.apache.kafkaesque.clients.consumer.ConsumerRecords$ConcatenatedIterable;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.ConsumerRecords$ConcatenatedIterable: void <init>(java.lang.Iterable)>(v);
return v;
}
public java.util.Set partitions()
{
org.apache.kafkaesque.clients.consumer.ConsumerRecords v;
java.util.Map v;
java.util.Set v, v;
v := @this: org.apache.kafkaesque.clients.consumer.ConsumerRecords;
v = v.<org.apache.kafkaesque.clients.consumer.ConsumerRecords: java.util.Map records>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = staticinvoke <java.util.Collections: java.util.Set unmodifiableSet(java.util.Set)>(v);
return v;
}
public java.util.Iterator iterator()
{
org.apache.kafkaesque.clients.consumer.ConsumerRecords v;
java.util.Iterator v;
java.util.Collection v;
java.util.Map v;
org.apache.kafkaesque.clients.consumer.ConsumerRecords$ConcatenatedIterable v;
v := @this: org.apache.kafkaesque.clients.consumer.ConsumerRecords;
v = new org.apache.kafkaesque.clients.consumer.ConsumerRecords$ConcatenatedIterable;
v = v.<org.apache.kafkaesque.clients.consumer.ConsumerRecords: java.util.Map records>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
specialinvoke v.<org.apache.kafkaesque.clients.consumer.ConsumerRecords$ConcatenatedIterable: void <init>(java.lang.Iterable)>(v);
v = virtualinvoke v.<org.apache.kafkaesque.clients.consumer.ConsumerRecords$ConcatenatedIterable: java.util.Iterator iterator()>();
return v;
}
public int count()
{
java.util.Iterator v;
java.util.Collection v;
org.apache.kafkaesque.clients.consumer.ConsumerRecords v;
java.util.Map v;
int v, v;
java.lang.Object v;
boolean v;
v := @this: org.apache.kafkaesque.clients.consumer.ConsumerRecords;
v = 0;
v = v.<org.apache.kafkaesque.clients.consumer.ConsumerRecords: java.util.Map records>;
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 = interfaceinvoke v.<java.util.List: int size()>();
v = v + v;
goto label;
label:
return v;
}
public boolean isEmpty()
{
org.apache.kafkaesque.clients.consumer.ConsumerRecords v;
boolean v;
java.util.Map v;
v := @this: org.apache.kafkaesque.clients.consumer.ConsumerRecords;
v = v.<org.apache.kafkaesque.clients.consumer.ConsumerRecords: java.util.Map records>;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
return v;
}
public static org.apache.kafkaesque.clients.consumer.ConsumerRecords empty()
{
org.apache.kafkaesque.clients.consumer.ConsumerRecords v;
v = <org.apache.kafkaesque.clients.consumer.ConsumerRecords: org.apache.kafkaesque.clients.consumer.ConsumerRecords EMPTY>;
return v;
}
static void <clinit>()
{
org.apache.kafkaesque.clients.consumer.ConsumerRecords v;
java.util.Map v;
v = new org.apache.kafkaesque.clients.consumer.ConsumerRecords;
v = <java.util.Collections: java.util.Map EMPTY_MAP>;
specialinvoke v.<org.apache.kafkaesque.clients.consumer.ConsumerRecords: void <init>(java.util.Map)>(v);
<org.apache.kafkaesque.clients.consumer.ConsumerRecords: org.apache.kafkaesque.clients.consumer.ConsumerRecords EMPTY> = v;
return;
}
}