public class org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan extends org.apache.drill.exec.physical.base.AbstractGroupScan
{
private final org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig storagePluginConfig;
private final org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec openTSDBScanSpec;
private final org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin storagePlugin;
private java.util.List columns;
public void <init>(org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec, org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig, 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.openTSDB.OpenTSDBGroupScan v;
org.apache.drill.exec.store.StoragePlugin v;
org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig v;
org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v := @parameter: org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec;
v := @parameter: org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig;
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/openTSDB/OpenTSDBStoragePlugin;");
specialinvoke v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: void <init>(org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin,org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec,java.util.List)>(v, v, v);
return;
}
public void <init>(org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin, org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec, java.util.List)
{
org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec v;
java.util.List v, v;
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v;
int v;
org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig v;
java.lang.String v;
org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v := @parameter: org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin;
v := @parameter: org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec;
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.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin storagePlugin> = v;
v = virtualinvoke v.<org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin: org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig getConfig()>();
v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig storagePluginConfig> = v;
v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec openTSDBScanSpec> = 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.openTSDB.OpenTSDBGroupScan: java.util.List ALL_COLUMNS>;
goto label;
label:
v = v;
label:
v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: java.util.List columns> = v;
return;
}
private void <init>(org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan)
{
java.util.List v;
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v, v;
org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig v;
java.lang.String v;
org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec v;
org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v := @parameter: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v = null;
specialinvoke v.<org.apache.drill.exec.physical.base.AbstractGroupScan: void <init>(java.lang.String)>(v);
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: java.util.List columns>;
v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: java.util.List columns> = v;
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec openTSDBScanSpec>;
v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec openTSDBScanSpec> = v;
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin storagePlugin>;
v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin storagePlugin> = v;
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig storagePluginConfig>;
v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig storagePluginConfig> = v;
return;
}
public int getMaxParallelizationWidth()
{
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
return 1;
}
public void applyAssignments(java.util.List)
{
java.util.List v;
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v := @parameter: java.util.List;
return;
}
public org.apache.drill.exec.store.openTSDB.OpenTSDBSubScan getSpecificScan(int)
{
org.apache.drill.exec.store.openTSDB.OpenTSDBSubScan$OpenTSDBSubScanSpec v;
org.apache.drill.exec.store.openTSDB.OpenTSDBSubScan v;
java.util.ArrayList v;
java.util.List v;
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v;
int v;
org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig v;
java.lang.String v;
org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v := @parameter: int;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList()>();
v = new org.apache.drill.exec.store.openTSDB.OpenTSDBSubScan$OpenTSDBSubScanSpec;
v = virtualinvoke v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: java.lang.String getTableName()>();
specialinvoke v.<org.apache.drill.exec.store.openTSDB.OpenTSDBSubScan$OpenTSDBSubScanSpec: void <init>(java.lang.String)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = new org.apache.drill.exec.store.openTSDB.OpenTSDBSubScan;
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin storagePlugin>;
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig storagePluginConfig>;
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: java.util.List columns>;
specialinvoke v.<org.apache.drill.exec.store.openTSDB.OpenTSDBSubScan: void <init>(org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin,org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig,java.util.List,java.util.List)>(v, v, v, v);
return v;
}
public org.apache.drill.exec.physical.base.ScanStats getScanStats()
{
java.util.Iterator v;
org.apache.drill.exec.physical.base.ScanStats v;
java.util.Set v;
long v;
org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec v;
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v;
byte v;
java.util.Map v;
org.apache.drill.exec.store.openTSDB.client.services.ServiceImpl v;
int v;
java.lang.Object v;
java.lang.String v;
org.apache.drill.exec.physical.base.ScanStats$GroupScanProperty v;
org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin storagePlugin>;
v = virtualinvoke v.<org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePlugin: org.apache.drill.exec.store.openTSDB.client.services.ServiceImpl getClient()>();
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec openTSDBScanSpec>;
v = virtualinvoke v.<org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec: java.lang.String getTableName()>();
v = staticinvoke <org.apache.drill.exec.store.openTSDB.Util: java.util.Map fromRowData(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.drill.exec.store.openTSDB.client.services.ServiceImpl: java.util.Set getAllMetrics(java.util.Map)>(v);
v = interfaceinvoke v.<java.util.Set: int size()>();
v = v cmp 0L;
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
staticinvoke <org.apache.drill.exec.store.openTSDB.SizeEstimator: long estimate(java.lang.Object)>(v);
label:
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 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, 0.0F);
return v;
}
public org.apache.drill.exec.physical.base.PhysicalOperator getNewWithChildren(java.util.List)
{
java.util.List v;
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v, v;
boolean v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
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.openTSDB.OpenTSDBGroupScan;
specialinvoke v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: void <init>(org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan)>(v);
return v;
}
public java.lang.String getDigest()
{
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v;
java.lang.String v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v = virtualinvoke v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: java.lang.String toString()>();
return v;
}
public boolean canPushdownProjects(java.util.List)
{
java.util.List v;
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v := @parameter: java.util.List;
return 1;
}
public java.lang.String getTableName()
{
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v;
java.lang.String v;
org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v = virtualinvoke v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec getOpenTSDBScanSpec()>();
v = virtualinvoke v.<org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec: java.lang.String getTableName()>();
return v;
}
public org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec getOpenTSDBScanSpec()
{
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v;
org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec openTSDBScanSpec>;
return v;
}
public org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig getStoragePluginConfig()
{
org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig v;
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBStoragePluginConfig storagePluginConfig>;
return v;
}
public java.util.List getColumns()
{
java.util.List v;
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: java.util.List columns>;
return v;
}
public org.apache.drill.exec.physical.base.GroupScan clone(java.util.List)
{
java.util.List v;
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v, v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v := @parameter: java.util.List;
v = new org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
specialinvoke v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: void <init>(org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan)>(v);
v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: java.util.List columns> = v;
return v;
}
public java.lang.String toString()
{
java.util.List v;
org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan v;
java.lang.String v;
org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec v;
v := @this: org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan;
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec openTSDBScanSpec>;
v = v.<org.apache.drill.exec.store.openTSDB.OpenTSDBGroupScan: java.util.List columns>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.drill.exec.store.openTSDB.OpenTSDBScanSpec,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[])>("OpenTSDBGroupScan [OpenTSDBScanSpec=\u, columns=\u]");
return v;
}
}