public class org.apache.drill.exec.store.kudu.KuduGroupScan extends org.apache.drill.exec.physical.base.AbstractGroupScan
{
private static final long DEFAULT_TABLET_SIZE;
private org.apache.drill.exec.store.kudu.KuduStoragePlugin kuduStoragePlugin;
private java.util.List columns;
private org.apache.drill.exec.store.kudu.KuduScanSpec kuduScanSpec;
private boolean filterPushedDown;
private java.util.List kuduWorkList;
private org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap assignments;
private java.util.List affinities;
public void <init>(org.apache.drill.exec.store.kudu.KuduScanSpec, org.apache.drill.exec.store.kudu.KuduStoragePluginConfig, java.util.List, org.apache.drill.exec.store.StoragePluginRegistry) throws java.io.IOException, org.apache.drill.common.exceptions.ExecutionSetupException
{
org.apache.drill.exec.store.StoragePluginRegistry v;
java.util.List v;
org.apache.drill.exec.store.kudu.KuduStoragePluginConfig v;
org.apache.drill.exec.store.StoragePlugin v;
org.apache.drill.exec.store.kudu.KuduGroupScan v;
org.apache.drill.exec.store.kudu.KuduScanSpec v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v := @parameter: org.apache.drill.exec.store.kudu.KuduScanSpec;
v := @parameter: org.apache.drill.exec.store.kudu.KuduStoragePluginConfig;
v := @parameter: java.util.List;
v := @parameter: org.apache.drill.exec.store.StoragePluginRegistry;
v = interfaceinvoke v.<org.apache.drill.exec.store.StoragePluginRegistry: org.apache.drill.exec.store.StoragePlugin resolve(org.apache.drill.common.logical.StoragePluginConfig,java.lang.Class)>(v, class "Lorg/apache/drill/exec/store/kudu/KuduStoragePlugin;");
specialinvoke v.<org.apache.drill.exec.store.kudu.KuduGroupScan: void <init>(org.apache.drill.exec.store.kudu.KuduStoragePlugin,org.apache.drill.exec.store.kudu.KuduScanSpec,java.util.List)>(v, v, v);
return;
}
public void <init>(org.apache.drill.exec.store.kudu.KuduStoragePlugin, org.apache.drill.exec.store.kudu.KuduScanSpec, java.util.List)
{
org.apache.drill.exec.store.kudu.KuduGroupScan v;
org.apache.drill.exec.store.kudu.KuduStoragePlugin v;
org.apache.drill.exec.store.kudu.KuduScanSpec v;
java.util.ArrayList v;
java.util.List v, v;
int v;
java.lang.String v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v := @parameter: org.apache.drill.exec.store.kudu.KuduStoragePlugin;
v := @parameter: org.apache.drill.exec.store.kudu.KuduScanSpec;
v := @parameter: java.util.List;
v = null;
specialinvoke v.<org.apache.drill.exec.physical.base.AbstractGroupScan: void <init>(java.lang.String)>(v);
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: boolean filterPushedDown> = 0;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List kuduWorkList> = v;
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduStoragePlugin kuduStoragePlugin> = v;
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduScanSpec kuduScanSpec> = v;
if v == null goto label;
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 0 goto label;
label:
v = <org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List ALL_COLUMNS>;
goto label;
label:
v = v;
label:
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List columns> = v;
specialinvoke v.<org.apache.drill.exec.store.kudu.KuduGroupScan: void init()>();
return;
}
private void init()
{
byte[] v, v;
org.apache.drill.exec.store.kudu.KuduScanSpec v;
boolean v, v, v;
java.util.Collection v;
org.apache.drill.exec.store.kudu.KuduStoragePlugin v, v;
org.apache.kudu.client.KuduClient v;
java.lang.Exception v;
java.util.List v, v, v;
org.apache.drill.exec.store.kudu.KuduGroupScan$KuduWork v;
java.util.HashMap v;
org.apache.drill.exec.server.DrillbitContext v;
org.apache.kudu.client.Partition v, v;
java.lang.String v, v, v;
org.apache.drill.exec.store.schedule.EndpointByteMap v;
java.util.Iterator v, v, v;
org.apache.drill.exec.store.kudu.KuduGroupScan v;
java.lang.RuntimeException v;
org.apache.kudu.client.KuduTable v;
java.lang.Object v, v, v, v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduScanSpec kuduScanSpec>;
v = virtualinvoke v.<org.apache.drill.exec.store.kudu.KuduScanSpec: java.lang.String getTableName()>();
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduStoragePlugin kuduStoragePlugin>;
v = virtualinvoke v.<org.apache.drill.exec.store.kudu.KuduStoragePlugin: org.apache.drill.exec.server.DrillbitContext getContext()>();
v = virtualinvoke v.<org.apache.drill.exec.server.DrillbitContext: java.util.Collection getBits()>();
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Maps: java.util.HashMap newHashMap()>();
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 = virtualinvoke v.<org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint: java.lang.String getAddress()>();
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.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduStoragePlugin kuduStoragePlugin>;
v = virtualinvoke v.<org.apache.drill.exec.store.kudu.KuduStoragePlugin: org.apache.kudu.client.KuduClient getClient()>();
v = virtualinvoke v.<org.apache.kudu.client.KuduClient: org.apache.kudu.client.KuduTable openTable(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.kudu.client.KuduTable: java.util.List getTabletsLocations(long)>(10000L);
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.drill.exec.store.kudu.KuduGroupScan$KuduWork;
v = virtualinvoke v.<org.apache.kudu.client.LocatedTablet: org.apache.kudu.client.Partition getPartition()>();
v = virtualinvoke v.<org.apache.kudu.client.Partition: byte[] getPartitionKeyStart()>();
v = virtualinvoke v.<org.apache.kudu.client.LocatedTablet: org.apache.kudu.client.Partition getPartition()>();
v = virtualinvoke v.<org.apache.kudu.client.Partition: byte[] getPartitionKeyEnd()>();
specialinvoke v.<org.apache.drill.exec.store.kudu.KuduGroupScan$KuduWork: void <init>(byte[],byte[])>(v, v);
v = virtualinvoke v.<org.apache.kudu.client.LocatedTablet: java.util.List getReplicas()>();
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 = virtualinvoke v.<org.apache.kudu.client.LocatedTablet$Replica: java.lang.String getRpcHost()>();
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.exec.store.kudu.KuduGroupScan$KuduWork: org.apache.drill.exec.store.schedule.EndpointByteMap getByteMap()>();
interfaceinvoke v.<org.apache.drill.exec.store.schedule.EndpointByteMap: void add(org.apache.drill.exec.proto.CoordinationProtos$DrillbitEndpoint,long)>(v, 1000L);
goto label;
label:
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List kuduWorkList>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
}
private void <init>(org.apache.drill.exec.store.kudu.KuduGroupScan)
{
org.apache.drill.exec.store.kudu.KuduGroupScan v, v;
org.apache.drill.exec.store.kudu.KuduStoragePlugin v;
org.apache.drill.exec.store.kudu.KuduScanSpec v;
java.util.ArrayList v;
java.util.List v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap v;
boolean v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v := @parameter: org.apache.drill.exec.store.kudu.KuduGroupScan;
specialinvoke v.<org.apache.drill.exec.physical.base.AbstractGroupScan: void <init>(org.apache.drill.exec.physical.base.AbstractGroupScan)>(v);
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: boolean filterPushedDown> = 0;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List kuduWorkList> = v;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduStoragePlugin kuduStoragePlugin>;
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduStoragePlugin kuduStoragePlugin> = v;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List columns>;
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List columns> = v;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduScanSpec kuduScanSpec>;
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduScanSpec kuduScanSpec> = v;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: boolean filterPushedDown>;
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: boolean filterPushedDown> = v;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List kuduWorkList>;
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List kuduWorkList> = v;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap assignments>;
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap assignments> = v;
return;
}
public org.apache.drill.exec.physical.base.GroupScan clone(java.util.List)
{
org.apache.drill.exec.store.kudu.KuduGroupScan v, v;
java.util.List v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v := @parameter: java.util.List;
v = new org.apache.drill.exec.store.kudu.KuduGroupScan;
specialinvoke v.<org.apache.drill.exec.store.kudu.KuduGroupScan: void <init>(org.apache.drill.exec.store.kudu.KuduGroupScan)>(v);
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List columns> = v;
return v;
}
public java.util.List getOperatorAffinity()
{
java.util.List v, v, v, v;
org.apache.drill.exec.store.kudu.KuduGroupScan v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List affinities>;
if v != null goto label;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List kuduWorkList>;
v = staticinvoke <org.apache.drill.exec.store.schedule.AffinityCreator: java.util.List getAffinityMap(java.util.List)>(v);
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List affinities> = v;
label:
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List affinities>;
return v;
}
public int getMaxParallelizationWidth()
{
int v;
org.apache.drill.exec.store.kudu.KuduGroupScan v;
java.util.List v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List kuduWorkList>;
v = interfaceinvoke v.<java.util.List: int size()>();
return v;
}
public void applyAssignments(java.util.List)
{
java.util.List v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap v;
org.apache.drill.exec.store.kudu.KuduGroupScan v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v := @parameter: java.util.List;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List kuduWorkList>;
v = staticinvoke <org.apache.drill.exec.store.schedule.AssignmentCreator: org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap getMappings(java.util.List,java.util.List)>(v, v);
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap assignments> = v;
return;
}
public org.apache.drill.exec.store.kudu.KuduSubScan getSpecificScan(int)
{
byte[] v, v;
org.apache.drill.exec.store.kudu.KuduSubScan$KuduSubScanSpec v;
java.lang.Integer v;
java.util.ArrayList v;
org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap v;
int v;
org.apache.drill.exec.store.kudu.KuduSubScan v;
java.lang.String v;
boolean v;
java.util.Iterator v;
org.apache.drill.exec.store.kudu.KuduGroupScan v;
org.apache.drill.exec.store.kudu.KuduStoragePlugin v;
java.util.List v, v;
java.lang.Object v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v := @parameter: int;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap assignments>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap: java.util.List get(java.lang.Object)>(v);
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
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.drill.exec.store.kudu.KuduSubScan$KuduSubScanSpec;
v = virtualinvoke v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.lang.String getTableName()>();
v = virtualinvoke v.<org.apache.drill.exec.store.kudu.KuduGroupScan$KuduWork: byte[] getPartitionKeyStart()>();
v = virtualinvoke v.<org.apache.drill.exec.store.kudu.KuduGroupScan$KuduWork: byte[] getPartitionKeyEnd()>();
specialinvoke v.<org.apache.drill.exec.store.kudu.KuduSubScan$KuduSubScanSpec: void <init>(java.lang.String,byte[],byte[])>(v, v, v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = new org.apache.drill.exec.store.kudu.KuduSubScan;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduStoragePlugin kuduStoragePlugin>;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List columns>;
specialinvoke v.<org.apache.drill.exec.store.kudu.KuduSubScan: void <init>(org.apache.drill.exec.store.kudu.KuduStoragePlugin,java.util.List,java.util.List)>(v, v, v);
return v;
}
public org.apache.drill.exec.physical.base.ScanStats getScanStats()
{
java.util.List v;
org.apache.drill.exec.physical.base.ScanStats v;
int v;
org.apache.drill.exec.store.kudu.KuduGroupScan v;
long v;
org.apache.drill.exec.physical.base.ScanStats$GroupScanProperty v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List kuduWorkList>;
v = interfaceinvoke v.<java.util.List: int size()>();
v = 100000L * v;
v = new org.apache.drill.exec.physical.base.ScanStats;
v = <org.apache.drill.exec.physical.base.ScanStats$GroupScanProperty: org.apache.drill.exec.physical.base.ScanStats$GroupScanProperty NO_EXACT_ROW_COUNT>;
specialinvoke v.<org.apache.drill.exec.physical.base.ScanStats: void <init>(org.apache.drill.exec.physical.base.ScanStats$GroupScanProperty,double,double,double)>(v, v, 1.0, v);
return v;
}
public org.apache.drill.exec.physical.base.PhysicalOperator getNewWithChildren(java.util.List)
{
java.util.List v;
org.apache.drill.exec.store.kudu.KuduGroupScan v, v;
boolean v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v := @parameter: java.util.List;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
staticinvoke <org.apache.drill.shaded.guava.com.google.common.base.Preconditions: void checkArgument(boolean)>(v);
v = new org.apache.drill.exec.store.kudu.KuduGroupScan;
specialinvoke v.<org.apache.drill.exec.store.kudu.KuduGroupScan: void <init>(org.apache.drill.exec.store.kudu.KuduGroupScan)>(v);
return v;
}
public org.apache.drill.exec.store.kudu.KuduStoragePlugin getStoragePlugin()
{
org.apache.drill.exec.store.kudu.KuduGroupScan v;
org.apache.drill.exec.store.kudu.KuduStoragePlugin v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduStoragePlugin kuduStoragePlugin>;
return v;
}
public java.lang.String getTableName()
{
org.apache.drill.exec.store.kudu.KuduGroupScan v;
java.lang.String v;
org.apache.drill.exec.store.kudu.KuduScanSpec v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v = virtualinvoke v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduScanSpec getKuduScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.kudu.KuduScanSpec: java.lang.String getTableName()>();
return v;
}
public java.lang.String getDigest()
{
org.apache.drill.exec.store.kudu.KuduGroupScan v;
java.lang.String v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v = virtualinvoke v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.lang.String toString()>();
return v;
}
public java.lang.String toString()
{
java.util.List v;
org.apache.drill.exec.store.kudu.KuduGroupScan v;
java.lang.String v;
org.apache.drill.exec.store.kudu.KuduScanSpec v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduScanSpec kuduScanSpec>;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List columns>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.drill.exec.store.kudu.KuduScanSpec,java.util.List)>(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[])>("KuduGroupScan [KuduScanSpec=\u, columns=\u]");
return v;
}
public org.apache.drill.exec.store.kudu.KuduStoragePluginConfig getKuduStoragePluginConfig()
{
org.apache.drill.exec.store.kudu.KuduGroupScan v;
org.apache.drill.exec.store.kudu.KuduStoragePluginConfig v;
org.apache.drill.exec.store.kudu.KuduStoragePlugin v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduStoragePlugin kuduStoragePlugin>;
v = virtualinvoke v.<org.apache.drill.exec.store.kudu.KuduStoragePlugin: org.apache.drill.exec.store.kudu.KuduStoragePluginConfig getConfig()>();
return v;
}
public java.util.List getColumns()
{
org.apache.drill.exec.store.kudu.KuduGroupScan v;
java.util.List v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List columns>;
return v;
}
public org.apache.drill.exec.store.kudu.KuduScanSpec getKuduScanSpec()
{
org.apache.drill.exec.store.kudu.KuduGroupScan v;
org.apache.drill.exec.store.kudu.KuduScanSpec v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduScanSpec kuduScanSpec>;
return v;
}
public boolean canPushdownProjects(java.util.List)
{
org.apache.drill.exec.store.kudu.KuduGroupScan v;
java.util.List v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v := @parameter: java.util.List;
return 1;
}
public void setFilterPushedDown(boolean)
{
org.apache.drill.exec.store.kudu.KuduGroupScan v;
boolean v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v := @parameter: boolean;
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: boolean filterPushedDown> = 1;
return;
}
public boolean isFilterPushedDown()
{
org.apache.drill.exec.store.kudu.KuduGroupScan v;
boolean v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v = v.<org.apache.drill.exec.store.kudu.KuduGroupScan: boolean filterPushedDown>;
return v;
}
public void <init>()
{
org.apache.drill.exec.store.kudu.KuduGroupScan v;
java.lang.String v;
java.util.ArrayList v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v = null;
specialinvoke v.<org.apache.drill.exec.physical.base.AbstractGroupScan: void <init>(java.lang.String)>(v);
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: boolean filterPushedDown> = 0;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: java.util.List kuduWorkList> = v;
return;
}
public void setKuduScanSpec(org.apache.drill.exec.store.kudu.KuduScanSpec)
{
org.apache.drill.exec.store.kudu.KuduGroupScan v;
org.apache.drill.exec.store.kudu.KuduScanSpec v;
v := @this: org.apache.drill.exec.store.kudu.KuduGroupScan;
v := @parameter: org.apache.drill.exec.store.kudu.KuduScanSpec;
v.<org.apache.drill.exec.store.kudu.KuduGroupScan: org.apache.drill.exec.store.kudu.KuduScanSpec kuduScanSpec> = v;
return;
}
}