public class org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder extends org.apache.drill.common.expression.visitors.AbstractExprVisitor implements java.lang.AutoCloseable
{
private final org.apache.drill.common.expression.LogicalExpression le;
private final org.apache.drill.exec.store.kafka.KafkaGroupScan groupScan;
private final org.apache.kafka.clients.consumer.KafkaConsumer kafkaConsumer;
private org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec;
public void <init>(org.apache.drill.exec.store.kafka.KafkaGroupScan, org.apache.drill.common.expression.LogicalExpression)
{
org.apache.kafka.common.serialization.ByteArrayDeserializer v, v;
java.util.Properties v;
org.apache.drill.exec.store.kafka.KafkaStoragePluginConfig v;
org.apache.drill.common.expression.LogicalExpression v;
org.apache.drill.exec.store.kafka.KafkaGroupScan v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder v;
org.apache.kafka.clients.consumer.KafkaConsumer v;
v := @this: org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder;
v := @parameter: org.apache.drill.exec.store.kafka.KafkaGroupScan;
v := @parameter: org.apache.drill.common.expression.LogicalExpression;
specialinvoke v.<org.apache.drill.common.expression.visitors.AbstractExprVisitor: void <init>()>();
v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.exec.store.kafka.KafkaGroupScan groupScan> = v;
v = new org.apache.kafka.clients.consumer.KafkaConsumer;
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaGroupScan: org.apache.drill.exec.store.kafka.KafkaStoragePluginConfig getKafkaStoragePluginConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaStoragePluginConfig: java.util.Properties getKafkaConsumerProps()>();
v = new org.apache.kafka.common.serialization.ByteArrayDeserializer;
specialinvoke v.<org.apache.kafka.common.serialization.ByteArrayDeserializer: void <init>()>();
v = new org.apache.kafka.common.serialization.ByteArrayDeserializer;
specialinvoke v.<org.apache.kafka.common.serialization.ByteArrayDeserializer: void <init>()>();
specialinvoke v.<org.apache.kafka.clients.consumer.KafkaConsumer: void <init>(java.util.Properties,org.apache.kafka.common.serialization.Deserializer,org.apache.kafka.common.serialization.Deserializer)>(v, v, v);
v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.kafka.clients.consumer.KafkaConsumer kafkaConsumer> = v;
v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.common.expression.LogicalExpression le> = v;
return;
}
public java.util.List parseTree()
{
long v, v;
org.apache.drill.exec.store.kafka.KafkaGroupScan v, v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder v;
int v, v;
java.lang.String v, v, v;
boolean v, v;
org.apache.kafka.common.TopicPartition v, v;
org.apache.drill.exec.store.kafka.KafkaScanSpec v;
java.util.Iterator v;
org.apache.drill.common.expression.LogicalExpression v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder v;
java.util.List v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap v, v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder builder()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.exec.store.kafka.KafkaGroupScan groupScan>;
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaGroupScan: java.util.List getPartitionScanSpecList()>();
v = interfaceinvoke v.<java.util.List: 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 = new org.apache.kafka.common.TopicPartition;
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: java.lang.String getTopicName()>();
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: int getPartitionId()>();
specialinvoke v.<org.apache.kafka.common.TopicPartition: void <init>(java.lang.String,int)>(v, v);
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap build()>();
v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec> = v;
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.common.expression.LogicalExpression le>;
v = interfaceinvoke v.<org.apache.drill.common.expression.LogicalExpression: java.lang.Object accept(org.apache.drill.common.expression.visitors.ExprVisitor,java.lang.Object)>(v, null);
if v == null goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
v = new org.apache.kafka.common.TopicPartition;
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.exec.store.kafka.KafkaGroupScan groupScan>;
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaGroupScan: org.apache.drill.exec.store.kafka.KafkaScanSpec getKafkaScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaScanSpec: java.lang.String getTopicName()>();
specialinvoke v.<org.apache.kafka.common.TopicPartition: void <init>(java.lang.String,int)>(v, 0);
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
return v;
}
public java.util.List visitUnknown(org.apache.drill.common.expression.LogicalExpression, java.lang.Void)
{
java.lang.Void v;
org.apache.drill.common.expression.LogicalExpression v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder v;
v := @this: org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder;
v := @parameter: org.apache.drill.common.expression.LogicalExpression;
v := @parameter: java.lang.Void;
return null;
}
public java.util.List visitBooleanOperator(org.apache.drill.common.expression.BooleanOperator, java.lang.Void)
{
boolean v, v, v, v, v;
java.lang.Void v;
org.apache.kafka.common.TopicPartition v, v;
java.util.function.Predicate v;
java.util.Collection v;
java.util.Set v;
java.util.List v;
org.apache.drill.common.expression.BooleanOperator v;
java.util.HashMap v;
java.util.ArrayList v;
java.util.HashSet v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder v;
int v, v;
java.lang.String v, v, v, v, v;
java.util.Iterator v, v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap v;
java.lang.Object v, v, v, v, v, v, v, v;
v := @this: org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder;
v := @parameter: org.apache.drill.common.expression.BooleanOperator;
v := @parameter: java.lang.Void;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Maps: java.util.HashMap newHashMap()>();
v = virtualinvoke v.<org.apache.drill.common.expression.BooleanOperator: java.util.List args()>();
v = virtualinvoke v.<org.apache.drill.common.expression.BooleanOperator: java.lang.String getName()>();
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("booleanOr");
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: 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.<org.apache.drill.common.expression.LogicalExpression: java.lang.Object accept(org.apache.drill.common.expression.visitors.ExprVisitor,java.lang.Object)>(v, null);
if v == null goto label;
v = interfaceinvoke v.<java.util.List: 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 = new org.apache.kafka.common.TopicPartition;
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: java.lang.String getTopicName()>();
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: int getPartitionId()>();
specialinvoke v.<org.apache.kafka.common.TopicPartition: void <init>(java.lang.String,int)>(v, v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.drill.common.expression.BooleanOperator: java.lang.String getName()>();
virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void mergeScanSpec(java.lang.String,org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
return null;
label:
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
interfaceinvoke v.<java.util.Map: void putAll(java.util.Map)>(v);
v = interfaceinvoke v.<java.util.List: 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.<org.apache.drill.common.expression.LogicalExpression: java.lang.Object accept(org.apache.drill.common.expression.visitors.ExprVisitor,java.lang.Object)>(v, null);
if v == null goto label;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Sets: java.util.HashSet newHashSet()>();
v = interfaceinvoke v.<java.util.List: 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 = new org.apache.kafka.common.TopicPartition;
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: java.lang.String getTopicName()>();
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: int getPartitionId()>();
specialinvoke v.<org.apache.kafka.common.TopicPartition: void <init>(java.lang.String,int)>(v, v);
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.drill.common.expression.BooleanOperator: java.lang.String getName()>();
virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void mergeScanSpec(java.lang.String,org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec)>(v, v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
v = staticinvoke <org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder$lambda_visitBooleanOperator_0__7: java.util.function.Predicate bootstrap$(java.util.Set)>(v);
interfaceinvoke v.<java.util.Set: boolean removeIf(java.util.function.Predicate)>(v);
goto label;
label:
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList(java.lang.Iterable)>(v);
return v;
}
public java.util.List visitFunctionCall(org.apache.drill.common.expression.FunctionCall, java.lang.Void)
{
org.apache.drill.exec.store.kafka.KafkaNodeProcessor v;
byte v;
java.lang.Long v, v, v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder v;
org.apache.drill.common.expression.FunctionCall v;
int v;
java.lang.String v, v, v, v, v;
boolean v, v, v, v, v;
java.lang.Void v;
java.util.List v, v, v;
v := @this: org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder;
v := @parameter: org.apache.drill.common.expression.FunctionCall;
v := @parameter: java.lang.Void;
v = virtualinvoke v.<org.apache.drill.common.expression.FunctionCall: java.lang.String getName()>();
v = staticinvoke <org.apache.drill.exec.store.kafka.KafkaNodeProcessor: boolean isPushdownFunction(java.lang.String)>(v);
if v == 0 goto label;
v = staticinvoke <org.apache.drill.exec.store.kafka.KafkaNodeProcessor: org.apache.drill.exec.store.kafka.KafkaNodeProcessor process(org.apache.drill.common.expression.FunctionCall)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaNodeProcessor: boolean isSuccess()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaNodeProcessor: java.lang.String getPath()>();
v = -1;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
lookupswitch(v)
{
case -1682544993: goto label;
case -1149451045: goto label;
case -1148852498: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("kafkaMsgTimestamp");
if v == 0 goto label;
v = 0;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("kafkaMsgOffset");
if v == 0 goto label;
v = 1;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("kafkaPartitionId");
if v == 0 goto label;
v = 2;
label:
tableswitch(v)
{
case 0: goto label;
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaNodeProcessor: java.lang.String getFunctionName()>();
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaNodeProcessor: java.lang.Long getValue()>();
v = specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: java.util.List createScanSpecForTimestamp(java.lang.String,java.lang.Long)>(v, v);
return v;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaNodeProcessor: java.lang.String getFunctionName()>();
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaNodeProcessor: java.lang.Long getValue()>();
v = specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: java.util.List createScanSpecForOffset(java.lang.String,java.lang.Long)>(v, v);
return v;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaNodeProcessor: java.lang.String getFunctionName()>();
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaNodeProcessor: java.lang.Long getValue()>();
v = specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: java.util.List createScanSpecForPartition(java.lang.String,java.lang.Long)>(v, v);
return v;
label:
return null;
}
private java.util.List createScanSpecForTimestamp(java.lang.String, java.lang.Long)
{
java.lang.Long v, v;
java.util.Map v;
org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator v, v;
boolean v, v, v;
org.apache.kafka.clients.consumer.KafkaConsumer v;
java.util.HashMap v;
long v, v, v, v, v, v;
java.util.ArrayList v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec v, v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder v;
int v, v;
java.lang.String v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap v, v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet v;
java.lang.Object v, v, v, v, v, v;
v := @this: org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Long;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Maps: java.util.HashMap newHashMap()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet keySet()>();
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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.<java.lang.String: boolean equals(java.lang.Object)>("greater_than");
if v == 0 goto label;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v + 1L;
goto label;
label:
v = virtualinvoke v.<java.lang.Long: long longValue()>();
label:
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.kafka.clients.consumer.KafkaConsumer kafkaConsumer>;
v = virtualinvoke v.<org.apache.kafka.clients.consumer.KafkaConsumer: java.util.Map offsetsForTimes(java.util.Map)>(v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = virtualinvoke v.<org.apache.kafka.clients.consumer.OffsetAndTimestamp: long offset()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
private java.util.List createScanSpecForOffset(java.lang.String, java.lang.Long)
{
byte v, v;
java.lang.Long v;
long 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.util.ArrayList v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder v;
java.lang.String v, v, v, v, v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator v, v, v, v, v;
boolean v, v, v, v, v, v, v, v, v, v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec v, v, v, v, v, v;
int v, v, v, v, v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap v, v, v, v, v, v, v, v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Long;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet keySet()>();
v = -1;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
lookupswitch(v)
{
case -1374681402: goto label;
case -60502455: goto label;
case 96757556: goto label;
case 365984903: goto label;
case 1994762890: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("equal");
if v == 0 goto label;
v = 0;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("greater_than_or_equal_to");
if v == 0 goto label;
v = 1;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("greater_than");
if v == 0 goto label;
v = 2;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("less_than_or_equal_to");
if v == 0 goto label;
v = 3;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("less_than");
if v == 0 goto label;
v = 4;
label:
tableswitch(v)
{
case 0: goto label;
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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.<java.lang.Long: long longValue()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getStartOffset()>();
v = v cmp v;
if v >= 0 goto label;
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = v + 1L;
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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.<java.lang.Long: long longValue()>();
v = specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: long bindOffsetToRange(org.apache.kafka.common.TopicPartition,long)>(v, v);
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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.<java.lang.Long: long longValue()>();
v = v + 1L;
v = specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: long bindOffsetToRange(org.apache.kafka.common.TopicPartition,long)>(v, v);
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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.<java.lang.Long: long longValue()>();
v = v + 1L;
v = specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: long bindOffsetToRange(org.apache.kafka.common.TopicPartition,long)>(v, v);
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getStartOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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.<java.lang.Long: long longValue()>();
v = specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: long bindOffsetToRange(org.apache.kafka.common.TopicPartition,long)>(v, v);
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getStartOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
private java.util.List createScanSpecForPartition(java.lang.String, java.lang.Long)
{
byte v, v, v, v, v, v, v;
java.lang.Long v;
long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.ArrayList v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder v;
java.lang.String v, v, v, v, v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator v, v, v, v, v, v;
boolean v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec v, v, v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Long;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet keySet()>();
v = -1;
v = virtualinvoke v.<java.lang.String: int hashCode()>();
lookupswitch(v)
{
case -1374681402: goto label;
case -60502455: goto label;
case 96757556: goto label;
case 365984903: goto label;
case 1614662344: goto label;
case 1994762890: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("equal");
if v == 0 goto label;
v = 0;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("not_equal");
if v == 0 goto label;
v = 1;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("greater_than_or_equal_to");
if v == 0 goto label;
v = 2;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("greater_than");
if v == 0 goto label;
v = 3;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("less_than_or_equal_to");
if v == 0 goto label;
v = 4;
goto label;
label:
v = virtualinvoke v.<java.lang.String: boolean equals(java.lang.Object)>("less_than");
if v == 0 goto label;
v = 5;
label:
tableswitch(v)
{
case 0: goto label;
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
default: goto label;
};
label:
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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.kafka.common.TopicPartition: int partition()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v cmp v;
if v != 0 goto label;
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getStartOffset()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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.kafka.common.TopicPartition: int partition()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v cmp v;
if v == 0 goto label;
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getStartOffset()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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.kafka.common.TopicPartition: int partition()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v cmp v;
if v < 0 goto label;
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getStartOffset()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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.kafka.common.TopicPartition: int partition()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v cmp v;
if v <= 0 goto label;
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getStartOffset()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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.kafka.common.TopicPartition: int partition()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v cmp v;
if v > 0 goto label;
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getStartOffset()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.UnmodifiableIterator 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.kafka.common.TopicPartition: int partition()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v cmp v;
if v >= 0 goto label;
v = new org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec;
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: java.lang.String topic()>();
v = virtualinvoke v.<org.apache.kafka.common.TopicPartition: int partition()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getStartOffset()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
specialinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: void <init>(java.lang.String,int,long,long)>(v, v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
public void close()
{
org.apache.drill.exec.store.kafka.KafkaGroupScan v;
org.apache.drill.exec.store.kafka.KafkaStoragePlugin v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder v;
org.apache.kafka.clients.consumer.KafkaConsumer v;
v := @this: org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder;
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.exec.store.kafka.KafkaGroupScan groupScan>;
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaGroupScan: org.apache.drill.exec.store.kafka.KafkaStoragePlugin getStoragePlugin()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.kafka.clients.consumer.KafkaConsumer kafkaConsumer>;
virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaStoragePlugin: void registerToClose(java.lang.AutoCloseable)>(v);
return;
}
private long bindOffsetToRange(org.apache.kafka.common.TopicPartition, long)
{
org.apache.kafka.common.TopicPartition v;
long v, v, v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap v, v;
org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder v;
java.lang.Object v, v;
v := @this: org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder;
v := @parameter: org.apache.kafka.common.TopicPartition;
v := @parameter: long;
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getStartOffset()>();
v = v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpecBuilder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap fullScanSpec>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableMap: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.kafka.KafkaPartitionScanSpec: long getEndOffset()>();
v = staticinvoke <java.lang.Math: long min(long,long)>(v, v);
v = staticinvoke <java.lang.Math: long max(long,long)>(v, v);
return v;
}
}