public class org.apache.drill.metastore.iceberg.operate.IcebergRead extends org.apache.drill.metastore.operate.AbstractRead
{
private final org.apache.drill.metastore.iceberg.IcebergMetastoreContext context;
private final java.lang.String[] defaultColumns;
public void <init>(org.apache.drill.metastore.operate.MetadataTypeValidator, org.apache.drill.metastore.iceberg.IcebergMetastoreContext)
{
org.apache.drill.metastore.operate.MetadataTypeValidator v;
java.lang.Object[] v;
org.apache.iceberg.Table v;
org.apache.iceberg.Schema v;
java.util.function.Function v;
org.apache.drill.metastore.iceberg.IcebergMetastoreContext v;
java.util.List v;
java.util.stream.Stream v, v;
org.apache.drill.metastore.iceberg.operate.IcebergRead v;
java.util.function.IntFunction v;
v := @this: org.apache.drill.metastore.iceberg.operate.IcebergRead;
v := @parameter: org.apache.drill.metastore.operate.MetadataTypeValidator;
v := @parameter: org.apache.drill.metastore.iceberg.IcebergMetastoreContext;
specialinvoke v.<org.apache.drill.metastore.operate.AbstractRead: void <init>(org.apache.drill.metastore.operate.MetadataTypeValidator)>(v);
v.<org.apache.drill.metastore.iceberg.operate.IcebergRead: org.apache.drill.metastore.iceberg.IcebergMetastoreContext context> = v;
v = interfaceinvoke v.<org.apache.drill.metastore.iceberg.IcebergMetastoreContext: org.apache.iceberg.Table table()>();
v = interfaceinvoke v.<org.apache.iceberg.Table: org.apache.iceberg.Schema schema()>();
v = virtualinvoke v.<org.apache.iceberg.Schema: java.util.List columns()>();
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.drill.metastore.iceberg.operate.IcebergRead$name__16: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <org.apache.drill.metastore.iceberg.operate.IcebergRead$lambda_new_0__17: java.util.function.IntFunction bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object[] toArray(java.util.function.IntFunction)>(v);
v.<org.apache.drill.metastore.iceberg.operate.IcebergRead: java.lang.String[] defaultColumns> = v;
return;
}
protected java.util.List internalExecute()
{
org.apache.iceberg.expressions.Expression[] v;
java.lang.Object[] v;
org.apache.drill.metastore.iceberg.transform.OutputDataTransformer v, v, v;
java.util.function.Function v;
java.util.ArrayList v;
org.apache.iceberg.expressions.Expression v, v, v;
org.apache.drill.metastore.iceberg.transform.FilterTransformer v;
boolean v;
java.util.function.IntFunction v;
org.apache.iceberg.io.CloseableIterable v;
org.apache.iceberg.Table v;
java.util.Set v;
org.apache.drill.metastore.expressions.FilterExpression v;
org.apache.drill.metastore.iceberg.IcebergMetastoreContext v, v, v;
java.util.List v, v, v;
org.apache.drill.metastore.iceberg.transform.Transformer v, v;
java.util.stream.Stream v, v;
org.apache.drill.metastore.iceberg.operate.IcebergRead v;
org.apache.iceberg.data.IcebergGenerics$ScanBuilder v, v, v;
v := @this: org.apache.drill.metastore.iceberg.operate.IcebergRead;
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergRead: java.util.List columns>;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v != 0 goto label;
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergRead: java.util.List columns>;
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.drill.metastore.iceberg.operate.IcebergRead$columnName__18: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <org.apache.drill.metastore.iceberg.operate.IcebergRead$lambda_internalExecute_1__19: java.util.function.IntFunction bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object[] toArray(java.util.function.IntFunction)>(v);
label:
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergRead: org.apache.drill.metastore.iceberg.IcebergMetastoreContext context>;
v = interfaceinvoke v.<org.apache.drill.metastore.iceberg.IcebergMetastoreContext: org.apache.drill.metastore.iceberg.transform.Transformer transformer()>();
v = interfaceinvoke v.<org.apache.drill.metastore.iceberg.transform.Transformer: org.apache.drill.metastore.iceberg.transform.FilterTransformer filter()>();
v = newarray (org.apache.iceberg.expressions.Expression)[2];
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergRead: java.util.Set metadataTypes>;
v = virtualinvoke v.<org.apache.drill.metastore.iceberg.transform.FilterTransformer: org.apache.iceberg.expressions.Expression transform(java.util.Set)>(v);
v[0] = v;
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergRead: org.apache.drill.metastore.expressions.FilterExpression filter>;
v = virtualinvoke v.<org.apache.drill.metastore.iceberg.transform.FilterTransformer: org.apache.iceberg.expressions.Expression transform(org.apache.drill.metastore.expressions.FilterExpression)>(v);
v[1] = v;
v = virtualinvoke v.<org.apache.drill.metastore.iceberg.transform.FilterTransformer: org.apache.iceberg.expressions.Expression combine(org.apache.iceberg.expressions.Expression[])>(v);
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergRead: org.apache.drill.metastore.iceberg.IcebergMetastoreContext context>;
v = interfaceinvoke v.<org.apache.drill.metastore.iceberg.IcebergMetastoreContext: org.apache.iceberg.Table table()>();
v = staticinvoke <org.apache.iceberg.data.IcebergGenerics: org.apache.iceberg.data.IcebergGenerics$ScanBuilder read(org.apache.iceberg.Table)>(v);
v = virtualinvoke v.<org.apache.iceberg.data.IcebergGenerics$ScanBuilder: org.apache.iceberg.data.IcebergGenerics$ScanBuilder select(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.iceberg.data.IcebergGenerics$ScanBuilder: org.apache.iceberg.data.IcebergGenerics$ScanBuilder where(org.apache.iceberg.expressions.Expression)>(v);
v = virtualinvoke v.<org.apache.iceberg.data.IcebergGenerics$ScanBuilder: org.apache.iceberg.io.CloseableIterable build()>();
v = v.<org.apache.drill.metastore.iceberg.operate.IcebergRead: org.apache.drill.metastore.iceberg.IcebergMetastoreContext context>;
v = interfaceinvoke v.<org.apache.drill.metastore.iceberg.IcebergMetastoreContext: org.apache.drill.metastore.iceberg.transform.Transformer transformer()>();
v = interfaceinvoke v.<org.apache.drill.metastore.iceberg.transform.Transformer: org.apache.drill.metastore.iceberg.transform.OutputDataTransformer outputData()>();
v = virtualinvoke v.<org.apache.drill.metastore.iceberg.transform.OutputDataTransformer: org.apache.drill.metastore.iceberg.transform.OutputDataTransformer columns(java.lang.String[])>(v);
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.ArrayList newArrayList(java.lang.Iterable)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.iceberg.transform.OutputDataTransformer: org.apache.drill.metastore.iceberg.transform.OutputDataTransformer records(java.util.List)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.iceberg.transform.OutputDataTransformer: java.util.List execute()>();
return v;
}
}