public class oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector extends java.lang.Object implements oadd.org.apache.drill.exec.metastore.analyze.MetadataInfoCollector
{
private final java.util.List metadataToRemove;
private final org.apache.drill.metastore.components.tables.BasicTablesRequests basicRequests;
private final org.apache.drill.metastore.metadata.TableInfo tableInfo;
private final org.apache.drill.metastore.metadata.MetadataType metadataLevel;
private java.util.List allMetaToHandle;
private java.util.List rowGroupsInfo;
private java.util.List filesInfo;
private org.apache.drill.shaded.guava.com.google.common.collect.Multimap segmentsInfo;
private oadd.org.apache.calcite.rel.core.TableScan tableScan;
private boolean outdated;
public void <init>(org.apache.drill.metastore.components.tables.BasicTablesRequests, org.apache.drill.metastore.metadata.TableInfo, oadd.org.apache.drill.exec.store.dfs.FormatSelection, oadd.org.apache.drill.exec.planner.physical.PlannerSettings, java.util.function.Supplier, java.util.List, org.apache.drill.metastore.metadata.MetadataType, int) throws java.io.IOException
{
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
org.apache.drill.metastore.metadata.MetadataType v;
org.apache.drill.metastore.metadata.TableInfo v;
oadd.org.apache.drill.exec.store.dfs.FormatSelection v;
org.apache.drill.shaded.guava.com.google.common.collect.ArrayListMultimap v;
java.util.function.Supplier v;
java.util.ArrayList v;
java.util.List v, v, v;
int v;
oadd.org.apache.drill.exec.planner.physical.PlannerSettings v;
org.apache.drill.metastore.components.tables.BasicTablesRequests v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v := @parameter: org.apache.drill.metastore.components.tables.BasicTablesRequests;
v := @parameter: org.apache.drill.metastore.metadata.TableInfo;
v := @parameter: oadd.org.apache.drill.exec.store.dfs.FormatSelection;
v := @parameter: oadd.org.apache.drill.exec.planner.physical.PlannerSettings;
v := @parameter: java.util.function.Supplier;
v := @parameter: java.util.List;
v := @parameter: org.apache.drill.metastore.metadata.MetadataType;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List rowGroupsInfo> = v;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List filesInfo> = v;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.ArrayListMultimap: org.apache.drill.shaded.guava.com.google.common.collect.ArrayListMultimap create()>();
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.shaded.guava.com.google.common.collect.Multimap segmentsInfo> = v;
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: boolean outdated> = 1;
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.metastore.components.tables.BasicTablesRequests basicRequests> = v;
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.metastore.metadata.TableInfo tableInfo> = v;
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.metastore.metadata.MetadataType metadataLevel> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List metadataToRemove> = v;
specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: void init(oadd.org.apache.drill.exec.store.dfs.FormatSelection,oadd.org.apache.drill.exec.planner.physical.PlannerSettings,java.util.function.Supplier,java.util.List,int)>(v, v, v, v, v);
return;
}
public java.util.List getRowGroupsInfo()
{
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
java.util.List v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List rowGroupsInfo>;
return v;
}
public java.util.List getFilesInfo()
{
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
java.util.List v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List filesInfo>;
return v;
}
public org.apache.drill.shaded.guava.com.google.common.collect.Multimap getSegmentsInfo()
{
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
org.apache.drill.shaded.guava.com.google.common.collect.Multimap v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.shaded.guava.com.google.common.collect.Multimap segmentsInfo>;
return v;
}
public java.util.List getAllMetaToHandle()
{
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
java.util.List v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List allMetaToHandle>;
return v;
}
public java.util.List getMetadataToRemove()
{
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
java.util.List v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List metadataToRemove>;
return v;
}
public oadd.org.apache.calcite.rel.core.TableScan getPrunedScan()
{
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
oadd.org.apache.calcite.rel.core.TableScan v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: oadd.org.apache.calcite.rel.core.TableScan tableScan>;
return v;
}
public boolean isOutdated()
{
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
boolean v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: boolean outdated>;
return v;
}
private void init(oadd.org.apache.drill.exec.store.dfs.FormatSelection, oadd.org.apache.drill.exec.planner.physical.PlannerSettings, java.util.function.Supplier, java.util.List, int) throws java.io.IOException
{
byte v;
java.util.Map v;
java.util.stream.Collector v, v, v, v;
java.util.stream.Stream[] v;
oadd.org.apache.drill.exec.store.dfs.FormatSelection v;
org.apache.drill.metastore.components.tables.TableMetadataUnit v;
java.util.Set v;
java.util.stream.Stream v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
long v, v;
java.util.function.Supplier v;
java.util.ArrayList v, v, v, v, v, v;
java.lang.String v, v;
org.apache.drill.metastore.statistics.TableStatisticsKind v;
oadd.org.apache.calcite.rel.core.TableScan v;
oadd.org.apache.drill.exec.planner.physical.PlannerSettings v;
org.apache.drill.metastore.metadata.MetadataType v, v, v, v, v, v, v, v;
org.apache.drill.metastore.metadata.BaseTableMetadata v;
java.net.URI v, v;
org.apache.drill.shaded.guava.com.google.common.collect.Multimap v;
boolean v, v, v, v, v, v;
org.apache.drill.metastore.components.tables.BasicTablesRequests v, v, v;
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
oadd.org.apache.drill.exec.store.dfs.FileSelection v;
java.util.function.Predicate v, v, v, v, v, v;
java.util.Collection v;
java.util.List v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.Optional v, v;
org.apache.drill.metastore.metadata.TableInfo v, v, v;
java.util.function.Function v, v;
int v, v, v;
java.util.Iterator v;
java.util.function.Consumer v;
java.lang.Object v, v, v, v, v, v, v, v, v, v;
oadd.org.apache.hadoop.fs.Path v, v, v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v := @parameter: oadd.org.apache.drill.exec.store.dfs.FormatSelection;
v := @parameter: oadd.org.apache.drill.exec.planner.physical.PlannerSettings;
v := @parameter: java.util.function.Supplier;
v := @parameter: java.util.List;
v := @parameter: int;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.metastore.components.tables.BasicTablesRequests basicRequests>;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.metastore.metadata.TableInfo tableInfo>;
v = virtualinvoke v.<org.apache.drill.metastore.components.tables.BasicTablesRequests: org.apache.drill.metastore.components.tables.TableMetadataUnit interestingColumnsAndPartitionKeys(org.apache.drill.metastore.metadata.TableInfo)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.components.tables.TableMetadataUnit: java.util.List interestingColumns()>();
v = staticinvoke <java.util.Optional: java.util.Optional ofNullable(java.lang.Object)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_init_0__496: java.util.function.Function bootstrap$()>();
v = virtualinvoke v.<java.util.Optional: java.util.Optional map(java.util.function.Function)>(v);
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(null);
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.metastore.components.tables.BasicTablesRequests basicRequests>;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.metastore.metadata.TableInfo tableInfo>;
v = virtualinvoke v.<org.apache.drill.metastore.components.tables.BasicTablesRequests: java.util.Map filesLastModifiedTime(org.apache.drill.metastore.metadata.TableInfo,java.lang.String,java.util.List)>(v, null, null);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = new java.util.ArrayList;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List getFileStatuses(oadd.org.apache.drill.exec.store.dfs.FormatSelection)>(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 = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: oadd.org.apache.hadoop.fs.Path getPath()>();
v = staticinvoke <oadd.org.apache.hadoop.fs.Path: oadd.org.apache.hadoop.fs.Path getPathWithoutSchemeAndAuthority(oadd.org.apache.hadoop.fs.Path)>(v);
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileStatus: long getModificationTime()>();
v = v cmp v;
if v >= 0 goto label;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
label:
interfaceinvoke v.<java.util.List: boolean remove(java.lang.Object)>(v);
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.dfs.FormatSelection: oadd.org.apache.drill.exec.store.dfs.FileSelection getSelection()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.dfs.FileSelection: oadd.org.apache.hadoop.fs.Path getSelectionRoot()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: java.net.URI toUri()>();
v = virtualinvoke v.<java.net.URI: java.lang.String getPath()>();
v = staticinvoke <java.util.Objects: boolean equals(java.lang.Object,java.lang.Object)>(v, v);
if v != 0 goto label;
if v == null goto label;
if v == null goto label;
v = interfaceinvoke v.<java.util.List: boolean containsAll(java.util.Collection)>(v);
if v == 0 goto label;
label:
v = <org.apache.drill.metastore.statistics.TableStatisticsKind: org.apache.drill.metastore.statistics.TableStatisticsKind ANALYZE_METADATA_LEVEL>;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.metastore.components.tables.BasicTablesRequests basicRequests>;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.metastore.metadata.TableInfo tableInfo>;
v = virtualinvoke v.<org.apache.drill.metastore.components.tables.BasicTablesRequests: org.apache.drill.metastore.metadata.BaseTableMetadata tableMetadata(org.apache.drill.metastore.metadata.TableInfo)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.statistics.TableStatisticsKind: java.lang.Object getValue(org.apache.drill.metastore.metadata.Metadata)>(v);
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.metastore.metadata.MetadataType metadataLevel>;
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataType: int compareTo(java.lang.Enum)>(v);
if v == 0 goto label;
label:
v = interfaceinvoke v.<java.util.function.Supplier: java.lang.Object get()>();
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: oadd.org.apache.calcite.rel.core.TableScan tableScan> = v;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List metadataToRemove>;
v = <org.apache.drill.metastore.metadata.MetadataType: org.apache.drill.metastore.metadata.MetadataType SEGMENT>;
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List getMetadataInfoList(java.lang.String,java.util.List,org.apache.drill.metastore.metadata.MetadataType,int)>(v, v, v, 0);
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
return;
label:
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
label:
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
v = interfaceinvoke v.<java.util.function.Supplier: java.lang.Object get()>();
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: oadd.org.apache.calcite.rel.core.TableScan getTableScan(oadd.org.apache.drill.exec.planner.physical.PlannerSettings,oadd.org.apache.calcite.rel.core.TableScan,java.util.List)>(v, v, v);
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: oadd.org.apache.calcite.rel.core.TableScan tableScan> = v;
v = v - 1;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
v = <org.apache.drill.metastore.metadata.MetadataType: org.apache.drill.metastore.metadata.MetadataType FILE>;
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List getMetadataInfoList(java.lang.String,java.util.List,org.apache.drill.metastore.metadata.MetadataType,int)>(v, v, v, 0);
v = <org.apache.drill.metastore.metadata.MetadataType: org.apache.drill.metastore.metadata.MetadataType SEGMENT>;
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List getMetadataInfoList(java.lang.String,java.util.List,org.apache.drill.metastore.metadata.MetadataType,int)>(v, v, v, v);
v = <org.apache.drill.metastore.metadata.MetadataType: org.apache.drill.metastore.metadata.MetadataType FILE>;
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List getMetadataInfoList(java.lang.String,java.util.List,org.apache.drill.metastore.metadata.MetadataType,int)>(v, v, v, 0);
v = <org.apache.drill.metastore.metadata.MetadataType: org.apache.drill.metastore.metadata.MetadataType FILE>;
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List getMetadataInfoList(java.lang.String,java.util.List,org.apache.drill.metastore.metadata.MetadataType,int)>(v, v, v, 0);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_init_2__497: java.util.function.Predicate bootstrap$(java.util.List)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_init_4__498: java.util.function.Function bootstrap$(java.util.List)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream flatMap(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List filesInfo> = v;
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.shaded.guava.com.google.common.collect.Multimap populateSegments(java.util.List,java.util.List,java.lang.String,int,java.util.List,java.util.List)>(v, v, v, v, v, v);
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List getAllRowGroupsMetadataInfos(java.util.List)>(v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_init_6__499: java.util.function.Predicate bootstrap$(oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List rowGroupsInfo> = v;
v = <org.apache.drill.metastore.metadata.MetadataType: org.apache.drill.metastore.metadata.MetadataType SEGMENT>;
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List getMetadataInfoList(java.lang.String,java.util.List,org.apache.drill.metastore.metadata.MetadataType,int)>(v, v, v, 0);
v = newarray (java.util.stream.Stream)[3];
v = interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.Multimap: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.stream.Stream stream()>();
v[0] = v;
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v[1] = v;
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v[2] = v;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Streams: java.util.stream.Stream concat(java.util.stream.Stream[])>(v);
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_init_8__500: java.util.function.Predicate bootstrap$(java.util.List)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_init_11__501: java.util.function.Predicate bootstrap$(oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector,java.util.List)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List allMetaToHandle> = v;
v = <org.apache.drill.metastore.metadata.MetadataType: org.apache.drill.metastore.metadata.MetadataType SEGMENT>;
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List getMetadataInfoList(java.lang.String,java.util.List,org.apache.drill.metastore.metadata.MetadataType,int)>(v, v, v, 0);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_init_14__502: java.util.function.Predicate bootstrap$(java.util.List,java.util.List)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List metadataToRemove>;
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_init_15__503: java.util.function.Predicate bootstrap$(java.util.List)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List allMetaToHandle>;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$add__504: java.util.function.Consumer bootstrap$(java.util.List)>(v);
interfaceinvoke v.<java.util.stream.Stream: void forEach(java.util.function.Consumer)>(v);
goto label;
label:
v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: boolean outdated> = 0;
label:
return;
}
private org.apache.drill.shaded.guava.com.google.common.collect.Multimap populateSegments(java.util.List, java.util.List, java.lang.String, int, java.util.List, java.util.List)
{
org.apache.drill.metastore.metadata.MetadataType v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ArrayListMultimap v;
java.lang.Integer v, v, v, v, v;
java.util.stream.Collector v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.Multimap v, v;
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
java.util.function.Predicate v, v, v, v;
java.util.Collection v;
java.util.List v, v, v, v, v, v, v;
java.util.stream.Stream v, v, v, v, v, v, v;
java.util.ArrayList v;
int v, v, v, v;
java.lang.String v;
java.lang.Object v, v, v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: int;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
interfaceinvoke v.<java.util.List: boolean addAll(java.util.Collection)>(v);
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.ArrayListMultimap: org.apache.drill.shaded.guava.com.google.common.collect.ArrayListMultimap create()>();
if v <= 0 goto label;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = <org.apache.drill.metastore.metadata.MetadataType: org.apache.drill.metastore.metadata.MetadataType SEGMENT>;
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List getMetadataInfoList(java.lang.String,java.util.List,org.apache.drill.metastore.metadata.MetadataType,int)>(v, v, v, v);
interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.Multimap: boolean putAll(java.lang.Object,java.lang.Iterable)>(v, v);
label:
v = v - 1;
label:
if v < 0 goto label;
v = <org.apache.drill.metastore.metadata.MetadataType: org.apache.drill.metastore.metadata.MetadataType SEGMENT>;
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List getMetadataInfoList(java.lang.String,java.util.List,org.apache.drill.metastore.metadata.MetadataType,int)>(v, v, v, v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.Multimap: boolean putAll(java.lang.Object,java.lang.Iterable)>(v, v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_populateSegments_17__506: java.util.function.Predicate bootstrap$(java.util.List)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = v + 1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.Multimap: java.util.Collection get(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.Collection: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_populateSegments_19__507: java.util.function.Predicate bootstrap$(java.util.List)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_populateSegments_22__508: java.util.function.Predicate bootstrap$(oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector,java.util.List)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.shaded.guava.com.google.common.collect.Multimap segmentsInfo>;
v = v + 1;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.Multimap: boolean putAll(java.lang.Object,java.lang.Iterable)>(v, v);
v = v;
v = v - 1;
goto label;
label:
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.shaded.guava.com.google.common.collect.Multimap segmentsInfo>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = <org.apache.drill.metastore.metadata.MetadataType: org.apache.drill.metastore.metadata.MetadataType SEGMENT>;
v = specialinvoke v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List getMetadataInfoList(java.lang.String,java.util.List,org.apache.drill.metastore.metadata.MetadataType,int)>(v, v, v, 0);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_populateSegments_25__505: java.util.function.Predicate bootstrap$(oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector,java.util.List)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
interfaceinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.Multimap: boolean putAll(java.lang.Object,java.lang.Iterable)>(v, v);
return v;
}
private java.util.List getAllRowGroupsMetadataInfos(java.util.List)
{
org.apache.drill.metastore.metadata.MetadataType v;
org.apache.drill.metastore.metadata.TableInfo v;
org.apache.drill.metastore.MetastoreColumn v, v, v;
java.util.function.Function v, v;
org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata v;
java.util.stream.Collector v, v;
org.apache.drill.metastore.components.tables.BasicTablesRequests v;
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
org.apache.drill.metastore.MetastoreColumn[] v;
java.util.List v, v, v, v;
java.util.stream.Stream v, v, v, v, v;
org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata$Builder v, v, v, v, v, v;
java.lang.Object v, v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v := @parameter: java.util.List;
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List filesInfo>;
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$key__509: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream distinct()>();
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = staticinvoke <org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata: org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata$Builder builder()>();
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.metastore.metadata.TableInfo tableInfo>;
v = virtualinvoke v.<org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata$Builder: org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata$Builder tableInfo(org.apache.drill.metastore.metadata.TableInfo)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata$Builder: org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata$Builder metadataKeys(java.util.List)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata$Builder: org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata$Builder paths(java.util.List)>(v);
v = <org.apache.drill.metastore.metadata.MetadataType: org.apache.drill.metastore.metadata.MetadataType ROW_GROUP>;
v = virtualinvoke v.<org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata$Builder: org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata$Builder metadataType(org.apache.drill.metastore.metadata.MetadataType)>(v);
v = newarray (org.apache.drill.metastore.MetastoreColumn)[3];
v = <org.apache.drill.metastore.MetastoreColumn: org.apache.drill.metastore.MetastoreColumn METADATA_KEY>;
v[0] = v;
v = <org.apache.drill.metastore.MetastoreColumn: org.apache.drill.metastore.MetastoreColumn METADATA_IDENTIFIER>;
v[1] = v;
v = <org.apache.drill.metastore.MetastoreColumn: org.apache.drill.metastore.MetastoreColumn METADATA_TYPE>;
v[2] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = virtualinvoke v.<org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata$Builder: org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata$Builder requestColumns(java.util.List)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata$Builder: org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata build()>();
v = v.<oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: org.apache.drill.metastore.components.tables.BasicTablesRequests basicRequests>;
v = virtualinvoke v.<org.apache.drill.metastore.components.tables.BasicTablesRequests: java.util.List request(org.apache.drill.metastore.components.tables.BasicTablesRequests$RequestMetadata)>(v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_getAllRowGroupsMetadataInfos_26__510: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
return v;
}
private java.util.List getFileStatuses(oadd.org.apache.drill.exec.store.dfs.FormatSelection) throws java.io.IOException
{
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
oadd.org.apache.drill.exec.store.dfs.FileSelection v;
oadd.org.apache.drill.exec.store.dfs.FormatSelection v;
java.util.List v;
oadd.org.apache.hadoop.conf.Configuration v, v;
java.lang.String v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.drill.exec.store.dfs.DrillFileSystem v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v := @parameter: oadd.org.apache.drill.exec.store.dfs.FormatSelection;
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.dfs.FormatSelection: oadd.org.apache.drill.exec.store.dfs.FileSelection getSelection()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.dfs.FileSelection: oadd.org.apache.hadoop.fs.Path getSelectionRoot()>();
v = new oadd.org.apache.hadoop.conf.Configuration;
specialinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: oadd.org.apache.hadoop.fs.FileSystem getFileSystem(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.util.ImpersonationUtil: java.lang.String getProcessUserName()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = staticinvoke <oadd.org.apache.drill.exec.util.ImpersonationUtil: oadd.org.apache.drill.exec.store.dfs.DrillFileSystem createFileSystem(java.lang.String,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: java.util.List getFileStatuses(oadd.org.apache.drill.exec.store.dfs.FileSelection,oadd.org.apache.drill.exec.store.dfs.DrillFileSystem)>(v, v);
return v;
}
private oadd.org.apache.calcite.rel.core.TableScan getTableScan(oadd.org.apache.drill.exec.planner.physical.PlannerSettings, oadd.org.apache.calcite.rel.core.TableScan, java.util.List)
{
oadd.org.apache.drill.exec.planner.logical.DrillTable v, v;
java.util.stream.Collector v;
boolean v;
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
oadd.org.apache.drill.exec.store.dfs.FileSelection v;
java.util.function.Predicate v;
java.lang.Exception v;
oadd.org.apache.calcite.plan.Convention v;
java.util.List v, v;
java.util.stream.Stream v, v, v, v;
oadd.org.apache.drill.exec.physical.base.SchemalessScan v;
oadd.org.apache.calcite.rel.type.RelDataType v;
oadd.org.apache.calcite.plan.RelOptCluster v;
oadd.org.apache.calcite.plan.RelTraitSet v, v;
java.util.function.Function v, v;
java.util.ArrayList v;
oadd.org.apache.drill.exec.planner.logical.DrillScanRel v;
java.lang.String v;
oadd.org.apache.drill.exec.planner.FileSystemPartitionDescriptor v;
java.util.Iterator v;
java.lang.RuntimeException v;
oadd.org.apache.calcite.plan.RelOptTable v, v;
java.lang.Object v, v;
oadd.org.apache.calcite.rel.core.TableScan v, v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.drill.exec.planner.physical.PlannerSettings v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v := @parameter: oadd.org.apache.drill.exec.planner.physical.PlannerSettings;
v := @parameter: oadd.org.apache.calcite.rel.core.TableScan;
v := @parameter: java.util.List;
v = new oadd.org.apache.drill.exec.planner.FileSystemPartitionDescriptor;
specialinvoke v.<oadd.org.apache.drill.exec.planner.FileSystemPartitionDescriptor: void <init>(oadd.org.apache.drill.exec.planner.physical.PlannerSettings,oadd.org.apache.calcite.rel.core.TableScan)>(v, v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.planner.FileSystemPartitionDescriptor: java.util.Iterator iterator()>();
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList(java.util.Iterator)>(v);
v = virtualinvoke v.<java.util.ArrayList: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$stream__511: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream flatMap(java.util.function.Function)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_getTableScan_27__512: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream flatMap(java.util.function.Function)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_getTableScan_28__513: java.util.function.Predicate bootstrap$(java.util.List)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
label:
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
v = virtualinvoke v.<oadd.org.apache.drill.exec.planner.FileSystemPartitionDescriptor: oadd.org.apache.calcite.rel.core.TableScan createTableScan(java.util.List,boolean)>(v, 0);
label:
return v;
label:
v = virtualinvoke v.<oadd.org.apache.drill.exec.planner.FileSystemPartitionDescriptor: oadd.org.apache.drill.exec.planner.logical.DrillTable getTable()>();
v = new oadd.org.apache.drill.exec.physical.base.SchemalessScan;
v = virtualinvoke v.<oadd.org.apache.drill.exec.planner.logical.DrillTable: java.lang.String getUserName()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.planner.FileSystemPartitionDescriptor: oadd.org.apache.drill.exec.planner.logical.DrillTable getTable()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.planner.logical.DrillTable: java.lang.Object getSelection()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.dfs.FormatSelection: oadd.org.apache.drill.exec.store.dfs.FileSelection getSelection()>();
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.dfs.FileSelection: oadd.org.apache.hadoop.fs.Path getSelectionRoot()>();
specialinvoke v.<oadd.org.apache.drill.exec.physical.base.SchemalessScan: void <init>(java.lang.String,oadd.org.apache.hadoop.fs.Path)>(v, v);
v = new oadd.org.apache.drill.exec.planner.logical.DrillScanRel;
v = virtualinvoke v.<oadd.org.apache.calcite.rel.core.TableScan: oadd.org.apache.calcite.plan.RelOptCluster getCluster()>();
v = virtualinvoke v.<oadd.org.apache.calcite.rel.core.TableScan: oadd.org.apache.calcite.plan.RelTraitSet getTraitSet()>();
v = <oadd.org.apache.drill.exec.planner.logical.DrillRel: oadd.org.apache.calcite.plan.Convention DRILL_LOGICAL>;
v = virtualinvoke v.<oadd.org.apache.calcite.plan.RelTraitSet: oadd.org.apache.calcite.plan.RelTraitSet plus(oadd.org.apache.calcite.plan.RelTrait)>(v);
v = virtualinvoke v.<oadd.org.apache.calcite.rel.core.TableScan: oadd.org.apache.calcite.plan.RelOptTable getTable()>();
v = virtualinvoke v.<oadd.org.apache.calcite.rel.core.TableScan: oadd.org.apache.calcite.rel.type.RelDataType getRowType()>();
v = virtualinvoke v.<oadd.org.apache.calcite.rel.core.TableScan: oadd.org.apache.calcite.plan.RelOptTable getTable()>();
v = staticinvoke <oadd.org.apache.drill.exec.planner.logical.DrillScanRel: java.util.List getProjectedColumns(oadd.org.apache.calcite.plan.RelOptTable,boolean)>(v, 1);
specialinvoke v.<oadd.org.apache.drill.exec.planner.logical.DrillScanRel: void <init>(oadd.org.apache.calcite.plan.RelOptCluster,oadd.org.apache.calcite.plan.RelTraitSet,oadd.org.apache.calcite.plan.RelOptTable,oadd.org.apache.drill.exec.physical.base.GroupScan,oadd.org.apache.calcite.rel.type.RelDataType,java.util.List,boolean)>(v, v, v, v, v, v, 1);
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String,java.lang.Throwable)>("Error happened during recreation of pruned scan", v);
throw v;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
}
private java.util.List getMetadataInfoList(java.lang.String, java.util.List, org.apache.drill.metastore.metadata.MetadataType, int)
{
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
org.apache.drill.metastore.metadata.MetadataType v;
java.util.function.Function v;
java.util.List v;
java.util.stream.Stream v, v, v;
int v;
java.lang.Object v;
java.lang.String v;
java.util.stream.Collector v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v := @parameter: org.apache.drill.metastore.metadata.MetadataType;
v := @parameter: int;
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$lambda_getMetadataInfoList_29__514: java.util.function.Function bootstrap$(oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector,java.lang.String,org.apache.drill.metastore.metadata.MetadataType,int)>(v, v, v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream distinct()>();
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
return v;
}
private org.apache.drill.metastore.metadata.MetadataInfo getMetadataInfo(java.lang.String, java.lang.String, org.apache.drill.metastore.metadata.MetadataType, int)
{
org.apache.drill.metastore.metadata.MetadataType v;
org.apache.drill.metastore.metadata.MetadataInfo v, v, v;
org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder v, v, v, v, v, v, v, v, v, v, v;
int[] v;
oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector v;
java.util.List v, v;
int v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v;
java.lang.UnsupportedOperationException v, v;
java.util.Iterator v, v;
java.lang.Object v, v;
oadd.org.apache.hadoop.fs.Path v, v;
v := @this: oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.drill.metastore.metadata.MetadataType;
v := @parameter: int;
v = new oadd.org.apache.hadoop.fs.Path;
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v = new oadd.org.apache.hadoop.fs.Path;
specialinvoke v.<oadd.org.apache.hadoop.fs.Path: void <init>(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.store.ColumnExplorer: java.util.List listPartitionValues(oadd.org.apache.hadoop.fs.Path,oadd.org.apache.hadoop.fs.Path,boolean)>(v, v, 1);
v = <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector$1: int[] $SwitchMap$org$apache$drill$metastore$metadata$MetadataType>;
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataType: int ordinal()>();
v = v[v];
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
default: goto label;
};
label:
v = new java.lang.UnsupportedOperationException;
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>("MetadataInfo cannot be obtained for row group using file location only");
throw v;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 1 goto label;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
goto label;
label:
v = "DEFAULT_SEGMENT";
label:
v = staticinvoke <org.apache.drill.metastore.metadata.MetadataInfo: org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder builder()>();
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder: org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder type(org.apache.drill.metastore.metadata.MetadataType)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder: org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder key(java.lang.String)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.MetadataIdentifierUtils: java.lang.String getMetadataIdentifierKey(java.util.List)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder: org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder identifier(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder: org.apache.drill.metastore.metadata.MetadataInfo build()>();
return v;
label:
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 1 goto label;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
goto label;
label:
v = "DEFAULT_SEGMENT";
label:
v = staticinvoke <org.apache.drill.metastore.metadata.MetadataInfo: org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder builder()>();
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder: org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder type(org.apache.drill.metastore.metadata.MetadataType)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder: org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder key(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.List: int size()>();
if v <= 1 goto label;
v = v + 1;
v = interfaceinvoke v.<java.util.List: java.util.List subList(int,int)>(0, v);
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.MetadataIdentifierUtils: java.lang.String getMetadataIdentifierKey(java.util.List)>(v);
goto label;
label:
v = "DEFAULT_SEGMENT";
label:
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder: org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder identifier(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder: org.apache.drill.metastore.metadata.MetadataInfo build()>();
return v;
label:
v = staticinvoke <org.apache.drill.metastore.metadata.MetadataInfo: org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder builder()>();
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder: org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder type(org.apache.drill.metastore.metadata.MetadataType)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder: org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder key(java.lang.String)>("GENERAL_INFO");
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataInfo$MetadataInfoBuilder: org.apache.drill.metastore.metadata.MetadataInfo build()>();
return v;
label:
v = new java.lang.UnsupportedOperationException;
v = virtualinvoke v.<org.apache.drill.metastore.metadata.MetadataType: java.lang.String name()>();
specialinvoke v.<java.lang.UnsupportedOperationException: void <init>(java.lang.String)>(v);
throw v;
}
public static java.util.List getFileStatuses(oadd.org.apache.drill.exec.store.dfs.FileSelection, oadd.org.apache.drill.exec.store.dfs.DrillFileSystem) throws java.io.IOException
{
java.util.List v;
oadd.org.apache.drill.exec.store.dfs.FileSelection v;
oadd.org.apache.drill.exec.store.dfs.DrillFileSystem v;
boolean v;
v := @parameter: oadd.org.apache.drill.exec.store.dfs.FileSelection;
v := @parameter: oadd.org.apache.drill.exec.store.dfs.DrillFileSystem;
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.dfs.FileSelection: boolean isExpandedFully()>();
if v != 0 goto label;
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: oadd.org.apache.drill.exec.store.dfs.FileSelection getExpandedFileSelection(oadd.org.apache.drill.exec.store.dfs.FileSelection,oadd.org.apache.hadoop.fs.FileSystem)>(v, v);
label:
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.dfs.FileSelection: java.util.List getStatuses(oadd.org.apache.drill.exec.store.dfs.DrillFileSystem)>(v);
return v;
}
public static oadd.org.apache.drill.exec.store.dfs.FileSelection getExpandedFileSelection(oadd.org.apache.drill.exec.store.dfs.FileSelection) throws java.io.IOException
{
oadd.org.apache.drill.exec.store.dfs.FileSelection v, v;
oadd.org.apache.hadoop.conf.Configuration v, v;
java.lang.String v;
oadd.org.apache.hadoop.fs.Path v;
oadd.org.apache.drill.exec.store.dfs.DrillFileSystem v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @parameter: oadd.org.apache.drill.exec.store.dfs.FileSelection;
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.dfs.FileSelection: oadd.org.apache.hadoop.fs.Path getSelectionRoot()>();
v = new oadd.org.apache.hadoop.conf.Configuration;
specialinvoke v.<oadd.org.apache.hadoop.conf.Configuration: void <init>()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.Path: oadd.org.apache.hadoop.fs.FileSystem getFileSystem(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = staticinvoke <oadd.org.apache.drill.exec.util.ImpersonationUtil: java.lang.String getProcessUserName()>();
v = virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem: oadd.org.apache.hadoop.conf.Configuration getConf()>();
v = staticinvoke <oadd.org.apache.drill.exec.util.ImpersonationUtil: oadd.org.apache.drill.exec.store.dfs.DrillFileSystem createFileSystem(java.lang.String,oadd.org.apache.hadoop.conf.Configuration)>(v, v);
v = staticinvoke <oadd.org.apache.drill.exec.metastore.analyze.FileMetadataInfoCollector: oadd.org.apache.drill.exec.store.dfs.FileSelection getExpandedFileSelection(oadd.org.apache.drill.exec.store.dfs.FileSelection,oadd.org.apache.hadoop.fs.FileSystem)>(v, v);
return v;
}
private static oadd.org.apache.drill.exec.store.dfs.FileSelection getExpandedFileSelection(oadd.org.apache.drill.exec.store.dfs.FileSelection, oadd.org.apache.hadoop.fs.FileSystem) throws java.io.IOException
{
java.util.List v;
oadd.org.apache.drill.exec.store.dfs.FileSelection v, v;
oadd.org.apache.hadoop.fs.PathFilter[] v;
oadd.org.apache.hadoop.fs.Path v, v;
oadd.org.apache.hadoop.fs.FileSystem v;
v := @parameter: oadd.org.apache.drill.exec.store.dfs.FileSelection;
v := @parameter: oadd.org.apache.hadoop.fs.FileSystem;
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.dfs.FileSelection: oadd.org.apache.hadoop.fs.Path getSelectionRoot()>();
v = newarray (oadd.org.apache.hadoop.fs.PathFilter)[0];
v = staticinvoke <oadd.org.apache.drill.exec.util.DrillFileSystemUtil: java.util.List listFiles(oadd.org.apache.hadoop.fs.FileSystem,oadd.org.apache.hadoop.fs.Path,boolean,oadd.org.apache.hadoop.fs.PathFilter[])>(v, v, 1, v);
v = virtualinvoke v.<oadd.org.apache.drill.exec.store.dfs.FileSelection: oadd.org.apache.hadoop.fs.Path getSelectionRoot()>();
v = staticinvoke <oadd.org.apache.drill.exec.store.dfs.FileSelection: oadd.org.apache.drill.exec.store.dfs.FileSelection create(java.util.List,java.util.List,oadd.org.apache.hadoop.fs.Path)>(v, null, v);
return v;
}
}