public class org.apache.drill.exec.store.druid.DruidGroupScan extends org.apache.drill.exec.physical.base.AbstractGroupScan
{
private static final org.slf4j.Logger logger;
private static final long DEFAULT_TABLET_SIZE;
private final org.apache.drill.exec.store.druid.DruidScanSpec scanSpec;
private final org.apache.drill.exec.store.druid.DruidStoragePlugin storagePlugin;
private java.util.List columns;
private boolean filterPushedDown;
private int maxRecordsToRead;
private java.util.List druidWorkList;
private org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap assignments;
private java.util.List affinities;
public void <init>(java.lang.String, org.apache.drill.exec.store.druid.DruidScanSpec, org.apache.drill.exec.store.druid.DruidStoragePluginConfig, java.util.List, int, org.apache.drill.exec.store.StoragePluginRegistry)
{
org.apache.drill.exec.store.StoragePluginRegistry v;
org.apache.drill.exec.store.StoragePlugin v;
java.util.List v;
org.apache.drill.exec.store.druid.DruidScanSpec v;
int v;
org.apache.drill.exec.store.druid.DruidGroupScan v;
org.apache.drill.exec.store.druid.DruidStoragePluginConfig v;
java.lang.String v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v := @parameter: java.lang.String;
v := @parameter: org.apache.drill.exec.store.druid.DruidScanSpec;
v := @parameter: org.apache.drill.exec.store.druid.DruidStoragePluginConfig;
v := @parameter: java.util.List;
v := @parameter: int;
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/druid/DruidStoragePlugin;");
specialinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: void <init>(java.lang.String,org.apache.drill.exec.store.druid.DruidStoragePlugin,org.apache.drill.exec.store.druid.DruidScanSpec,java.util.List,int)>(v, v, v, v, v);
return;
}
public void <init>(java.lang.String, org.apache.drill.exec.store.druid.DruidStoragePlugin, org.apache.drill.exec.store.druid.DruidScanSpec, java.util.List, int)
{
java.util.ArrayList v;
java.util.List v, v;
org.apache.drill.exec.store.druid.DruidScanSpec v;
int v, v;
org.apache.drill.exec.store.druid.DruidGroupScan v;
java.lang.String v;
org.apache.drill.exec.store.druid.DruidStoragePlugin v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v := @parameter: java.lang.String;
v := @parameter: org.apache.drill.exec.store.druid.DruidStoragePlugin;
v := @parameter: org.apache.drill.exec.store.druid.DruidScanSpec;
v := @parameter: java.util.List;
v := @parameter: int;
specialinvoke v.<org.apache.drill.exec.physical.base.AbstractGroupScan: void <init>(java.lang.String)>(v);
v.<org.apache.drill.exec.store.druid.DruidGroupScan: boolean filterPushedDown> = 0;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List druidWorkList> = v;
v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidStoragePlugin storagePlugin> = v;
v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidScanSpec scanSpec> = 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.druid.DruidGroupScan: java.util.List ALL_COLUMNS>;
goto label;
label:
v = v;
label:
v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List columns> = v;
v.<org.apache.drill.exec.store.druid.DruidGroupScan: int maxRecordsToRead> = v;
specialinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: void init()>();
return;
}
private void <init>(org.apache.drill.exec.store.druid.DruidGroupScan)
{
java.util.ArrayList v;
java.util.List v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap v;
org.apache.drill.exec.store.druid.DruidScanSpec v;
int v;
org.apache.drill.exec.store.druid.DruidGroupScan v, v;
org.apache.drill.exec.store.druid.DruidStoragePlugin v;
boolean v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v := @parameter: org.apache.drill.exec.store.druid.DruidGroupScan;
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.druid.DruidGroupScan: boolean filterPushedDown> = 0;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List druidWorkList> = v;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List columns>;
v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List columns> = v;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: int maxRecordsToRead>;
v.<org.apache.drill.exec.store.druid.DruidGroupScan: int maxRecordsToRead> = v;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidScanSpec scanSpec>;
v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidScanSpec scanSpec> = v;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidStoragePlugin storagePlugin>;
v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidStoragePlugin storagePlugin> = v;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: boolean filterPushedDown>;
v.<org.apache.drill.exec.store.druid.DruidGroupScan: boolean filterPushedDown> = v;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List druidWorkList>;
v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List druidWorkList> = v;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap assignments>;
v.<org.apache.drill.exec.store.druid.DruidGroupScan: 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.druid.DruidGroupScan v, v;
java.util.List v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v := @parameter: java.util.List;
v = new org.apache.drill.exec.store.druid.DruidGroupScan;
specialinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: void <init>(org.apache.drill.exec.store.druid.DruidGroupScan)>(v);
v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List columns> = v;
return v;
}
public org.apache.drill.exec.physical.base.GroupScan clone(int)
{
int v;
org.apache.drill.exec.store.druid.DruidGroupScan v, v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v := @parameter: int;
v = new org.apache.drill.exec.store.druid.DruidGroupScan;
specialinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: void <init>(org.apache.drill.exec.store.druid.DruidGroupScan)>(v);
v.<org.apache.drill.exec.store.druid.DruidGroupScan: int maxRecordsToRead> = v;
return v;
}
public java.util.List getOperatorAffinity()
{
java.util.List v, v, v, v;
org.apache.drill.exec.store.druid.DruidGroupScan v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List affinities>;
if v != null goto label;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List druidWorkList>;
v = staticinvoke <org.apache.drill.exec.store.schedule.AffinityCreator: java.util.List getAffinityMap(java.util.List)>(v);
v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List affinities> = v;
label:
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List affinities>;
return v;
}
public boolean canPushdownProjects(java.util.List)
{
org.apache.drill.exec.store.druid.DruidGroupScan v;
java.util.List v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v := @parameter: java.util.List;
return 1;
}
public boolean supportsLimitPushdown()
{
org.apache.drill.exec.store.druid.DruidGroupScan v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
return 1;
}
public org.apache.drill.exec.physical.base.GroupScan applyLimit(int)
{
int v, v;
org.apache.drill.exec.store.druid.DruidGroupScan v;
org.apache.drill.exec.physical.base.GroupScan v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v := @parameter: int;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: int maxRecordsToRead>;
if v != v goto label;
return null;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.physical.base.GroupScan clone(int)>(v);
return v;
}
public boolean isFilterPushedDown()
{
org.apache.drill.exec.store.druid.DruidGroupScan v;
boolean v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: boolean filterPushedDown>;
return v;
}
public void setFilterPushedDown(boolean)
{
org.apache.drill.exec.store.druid.DruidGroupScan v;
boolean v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v := @parameter: boolean;
v.<org.apache.drill.exec.store.druid.DruidGroupScan: boolean filterPushedDown> = v;
return;
}
private void init()
{
org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec v;
org.slf4j.Logger v;
org.apache.drill.exec.store.druid.common.DruidFilter v, v;
long v;
java.util.List v;
org.apache.drill.exec.store.druid.DruidScanSpec v, v;
org.apache.drill.exec.store.druid.DruidGroupScan$DruidWork v;
org.apache.drill.exec.store.druid.DruidGroupScan v;
java.lang.String v, v, v, v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = <org.apache.drill.exec.store.druid.DruidGroupScan: org.slf4j.Logger logger>;
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.lang.String getTableName()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidScanSpec getScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidScanSpec: org.apache.drill.exec.store.druid.common.DruidFilter getFilter()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object,java.lang.Object)>("Adding Druid Work for Table - {}. Filter - {}", v, v);
v = new org.apache.drill.exec.store.druid.DruidGroupScan$DruidWork;
v = new org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec;
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.lang.String getTableName()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidScanSpec getScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidScanSpec: org.apache.drill.exec.store.druid.common.DruidFilter getFilter()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: long getDatasourceSize()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.lang.String getDataSourceMinTime()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.lang.String getDataSourceMaxTime()>();
specialinvoke v.<org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec: void <init>(java.lang.String,org.apache.drill.exec.store.druid.common.DruidFilter,long,java.lang.String,java.lang.String)>(v, v, v, v, v);
specialinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan$DruidWork: void <init>(org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec)>(v);
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List druidWorkList>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
public org.apache.drill.exec.physical.base.ScanStats getScanStats()
{
org.apache.drill.exec.physical.base.ScanStats v;
long v, v;
java.util.List v;
int v, v;
org.apache.drill.exec.store.druid.DruidGroupScan v;
org.apache.drill.exec.store.druid.DruidStoragePluginConfig v;
org.apache.drill.exec.physical.base.ScanStats$GroupScanProperty v;
org.apache.drill.exec.store.druid.DruidStoragePlugin v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List druidWorkList>;
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>;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidStoragePlugin storagePlugin>;
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidStoragePlugin: org.apache.drill.exec.store.druid.DruidStoragePluginConfig getConfig()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidStoragePluginConfig: int getAverageRowSizeBytes()>();
v = v * v;
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 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.druid.DruidGroupScan v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v := @parameter: java.util.List;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List druidWorkList>;
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.druid.DruidGroupScan: org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap assignments> = v;
return;
}
public org.apache.drill.exec.store.druid.DruidSubScan getSpecificScan(int)
{
org.apache.drill.exec.store.druid.common.DruidFilter v;
long v;
java.lang.Integer v;
java.util.ArrayList v;
org.apache.drill.shaded.guava.com.google.common.collect.ListMultimap v;
int v, v;
org.apache.drill.exec.store.druid.DruidGroupScan v;
java.lang.String v, v, v, v;
boolean v;
org.apache.drill.exec.store.druid.DruidSubScan v;
org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec v, v, v, v, v, v;
java.util.Iterator v;
java.util.List v, v;
java.lang.Object v;
org.apache.drill.exec.store.druid.DruidStoragePlugin v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v := @parameter: int;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: 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.druid.DruidSubScan$DruidSubScanSpec;
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan$DruidWork: org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec getDruidSubScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec: java.lang.String getDataSourceName()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan$DruidWork: org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec getDruidSubScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec: org.apache.drill.exec.store.druid.common.DruidFilter getFilter()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan$DruidWork: org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec getDruidSubScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec: long getDataSourceSize()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan$DruidWork: org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec getDruidSubScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec: java.lang.String getMinTime()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan$DruidWork: org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec getDruidSubScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec: java.lang.String getMaxTime()>();
specialinvoke v.<org.apache.drill.exec.store.druid.DruidSubScan$DruidSubScanSpec: void <init>(java.lang.String,org.apache.drill.exec.store.druid.common.DruidFilter,long,java.lang.String,java.lang.String)>(v, 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.druid.DruidSubScan;
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.lang.String getUserName()>();
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidStoragePlugin storagePlugin>;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List columns>;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: int maxRecordsToRead>;
specialinvoke v.<org.apache.drill.exec.store.druid.DruidSubScan: void <init>(java.lang.String,org.apache.drill.exec.store.druid.DruidStoragePlugin,java.util.List,java.util.List,int)>(v, v, v, v, v);
return v;
}
public java.lang.String getTableName()
{
org.apache.drill.exec.store.druid.DruidGroupScan v;
java.lang.String v;
org.apache.drill.exec.store.druid.DruidScanSpec v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidScanSpec getScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidScanSpec: java.lang.String getDataSourceName()>();
return v;
}
public long getDatasourceSize()
{
org.apache.drill.exec.store.druid.DruidGroupScan v;
long v;
org.apache.drill.exec.store.druid.DruidScanSpec v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidScanSpec getScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidScanSpec: long getDataSourceSize()>();
return v;
}
public java.lang.String getDataSourceMinTime()
{
org.apache.drill.exec.store.druid.DruidGroupScan v;
java.lang.String v;
org.apache.drill.exec.store.druid.DruidScanSpec v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidScanSpec getScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidScanSpec: java.lang.String getDataSourceMinTime()>();
return v;
}
public java.lang.String getDataSourceMaxTime()
{
org.apache.drill.exec.store.druid.DruidGroupScan v;
java.lang.String v;
org.apache.drill.exec.store.druid.DruidScanSpec v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidScanSpec getScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidScanSpec: java.lang.String getDataSourceMaxTime()>();
return v;
}
public int getMaxParallelizationWidth()
{
int v;
org.apache.drill.exec.store.druid.DruidGroupScan v;
java.util.List v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List druidWorkList>;
v = interfaceinvoke v.<java.util.List: int size()>();
return v;
}
public java.lang.String getDigest()
{
org.apache.drill.exec.store.druid.DruidGroupScan v;
java.lang.String v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = virtualinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.lang.String toString()>();
return v;
}
public org.apache.drill.exec.store.druid.DruidScanSpec getScanSpec()
{
org.apache.drill.exec.store.druid.DruidGroupScan v;
org.apache.drill.exec.store.druid.DruidScanSpec v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidScanSpec scanSpec>;
return v;
}
public org.apache.drill.exec.store.druid.DruidStoragePlugin getStoragePlugin()
{
org.apache.drill.exec.store.druid.DruidGroupScan v;
org.apache.drill.exec.store.druid.DruidStoragePlugin v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidStoragePlugin storagePlugin>;
return v;
}
public java.util.List getColumns()
{
org.apache.drill.exec.store.druid.DruidGroupScan v;
java.util.List v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List columns>;
return v;
}
public int getMaxRecordsToRead()
{
int v;
org.apache.drill.exec.store.druid.DruidGroupScan v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: int maxRecordsToRead>;
return v;
}
public java.lang.String toString()
{
org.apache.drill.common.PlanStringBuilder v, v, v, v;
java.util.List v;
org.apache.drill.exec.store.druid.DruidScanSpec v;
org.apache.drill.exec.store.druid.DruidGroupScan v;
java.lang.String v;
org.apache.drill.exec.store.druid.DruidStoragePlugin v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
v = new org.apache.drill.common.PlanStringBuilder;
specialinvoke v.<org.apache.drill.common.PlanStringBuilder: void <init>(java.lang.Object)>(v);
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidScanSpec scanSpec>;
v = virtualinvoke v.<org.apache.drill.common.PlanStringBuilder: org.apache.drill.common.PlanStringBuilder field(java.lang.String,java.lang.Object)>("druidScanSpec", v);
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: java.util.List columns>;
v = virtualinvoke v.<org.apache.drill.common.PlanStringBuilder: org.apache.drill.common.PlanStringBuilder field(java.lang.String,java.lang.Object)>("columns", v);
v = v.<org.apache.drill.exec.store.druid.DruidGroupScan: org.apache.drill.exec.store.druid.DruidStoragePlugin storagePlugin>;
v = virtualinvoke v.<org.apache.drill.common.PlanStringBuilder: org.apache.drill.common.PlanStringBuilder field(java.lang.String,java.lang.Object)>("druidStoragePlugin", v);
v = virtualinvoke v.<org.apache.drill.common.PlanStringBuilder: java.lang.String toString()>();
return v;
}
public org.apache.drill.exec.physical.base.PhysicalOperator getNewWithChildren(java.util.List)
{
java.util.List v;
org.apache.drill.exec.store.druid.DruidGroupScan v, v;
boolean v;
v := @this: org.apache.drill.exec.store.druid.DruidGroupScan;
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.druid.DruidGroupScan;
specialinvoke v.<org.apache.drill.exec.store.druid.DruidGroupScan: void <init>(org.apache.drill.exec.store.druid.DruidGroupScan)>(v);
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/drill/exec/store/druid/DruidGroupScan;");
<org.apache.drill.exec.store.druid.DruidGroupScan: org.slf4j.Logger logger> = v;
return;
}
}