public class org.apache.drill.metastore.mongo.operate.MongoRead extends org.apache.drill.metastore.operate.AbstractRead
{
private final org.apache.drill.metastore.mongo.MongoMetastoreContext context;
public void <init>(org.apache.drill.metastore.operate.MetadataTypeValidator, org.apache.drill.metastore.mongo.MongoMetastoreContext)
{
org.apache.drill.metastore.mongo.MongoMetastoreContext v;
org.apache.drill.metastore.operate.MetadataTypeValidator v;
org.apache.drill.metastore.mongo.operate.MongoRead v;
v := @this: org.apache.drill.metastore.mongo.operate.MongoRead;
v := @parameter: org.apache.drill.metastore.operate.MetadataTypeValidator;
v := @parameter: org.apache.drill.metastore.mongo.MongoMetastoreContext;
specialinvoke v.<org.apache.drill.metastore.operate.AbstractRead: void <init>(org.apache.drill.metastore.operate.MetadataTypeValidator)>(v);
v.<org.apache.drill.metastore.mongo.operate.MongoRead: org.apache.drill.metastore.mongo.MongoMetastoreContext context> = v;
return;
}
protected java.util.List internalExecute()
{
com.mongodb.client.MongoCollection v;
org.apache.drill.metastore.mongo.MongoMetastoreContext v, v, v;
java.util.function.Function v;
org.bson.conversions.Bson v, v, v;
org.apache.drill.metastore.mongo.transform.OutputDataTransformer v, v, v;
java.util.stream.Collector v;
org.apache.drill.metastore.mongo.operate.MongoRead v;
java.util.LinkedList v;
org.apache.drill.metastore.mongo.transform.Transformer v, v;
org.bson.conversions.Bson[] v;
java.util.Set v;
org.apache.drill.metastore.mongo.transform.FilterTransformer v;
org.apache.drill.metastore.expressions.FilterExpression v;
java.util.function.Consumer v;
java.util.List v, v;
java.util.stream.Stream v, v;
com.mongodb.client.FindIterable v;
java.lang.Object v;
v := @this: org.apache.drill.metastore.mongo.operate.MongoRead;
v = v.<org.apache.drill.metastore.mongo.operate.MongoRead: org.apache.drill.metastore.mongo.MongoMetastoreContext context>;
v = interfaceinvoke v.<org.apache.drill.metastore.mongo.MongoMetastoreContext: org.apache.drill.metastore.mongo.transform.Transformer transformer()>();
v = interfaceinvoke v.<org.apache.drill.metastore.mongo.transform.Transformer: org.apache.drill.metastore.mongo.transform.FilterTransformer filter()>();
v = newarray (org.bson.conversions.Bson)[2];
v = v.<org.apache.drill.metastore.mongo.operate.MongoRead: java.util.Set metadataTypes>;
v = virtualinvoke v.<org.apache.drill.metastore.mongo.transform.FilterTransformer: org.bson.conversions.Bson transform(java.util.Set)>(v);
v[0] = v;
v = v.<org.apache.drill.metastore.mongo.operate.MongoRead: org.apache.drill.metastore.expressions.FilterExpression filter>;
v = virtualinvoke v.<org.apache.drill.metastore.mongo.transform.FilterTransformer: org.bson.conversions.Bson transform(org.apache.drill.metastore.expressions.FilterExpression)>(v);
v[1] = v;
v = virtualinvoke v.<org.apache.drill.metastore.mongo.transform.FilterTransformer: org.bson.conversions.Bson combine(org.bson.conversions.Bson[])>(v);
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.Lists: java.util.LinkedList newLinkedList()>();
v = v.<org.apache.drill.metastore.mongo.operate.MongoRead: org.apache.drill.metastore.mongo.MongoMetastoreContext context>;
v = interfaceinvoke v.<org.apache.drill.metastore.mongo.MongoMetastoreContext: com.mongodb.client.MongoCollection table()>();
v = interfaceinvoke v.<com.mongodb.client.MongoCollection: com.mongodb.client.FindIterable find(org.bson.conversions.Bson)>(v);
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.apache.drill.metastore.mongo.operate.MongoRead$add__4: java.util.function.Consumer bootstrap$(java.util.List)>(v);
interfaceinvoke v.<com.mongodb.client.FindIterable: void forEach(java.util.function.Consumer)>(v);
v = v.<org.apache.drill.metastore.mongo.operate.MongoRead: org.apache.drill.metastore.mongo.MongoMetastoreContext context>;
v = interfaceinvoke v.<org.apache.drill.metastore.mongo.MongoMetastoreContext: org.apache.drill.metastore.mongo.transform.Transformer transformer()>();
v = interfaceinvoke v.<org.apache.drill.metastore.mongo.transform.Transformer: org.apache.drill.metastore.mongo.transform.OutputDataTransformer outputData()>();
v = v.<org.apache.drill.metastore.mongo.operate.MongoRead: java.util.List columns>;
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.drill.metastore.mongo.operate.MongoRead$columnName__5: 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);
v = virtualinvoke v.<org.apache.drill.metastore.mongo.transform.OutputDataTransformer: org.apache.drill.metastore.mongo.transform.OutputDataTransformer columns(java.util.List)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.mongo.transform.OutputDataTransformer: org.apache.drill.metastore.mongo.transform.OutputDataTransformer documents(java.util.List)>(v);
v = virtualinvoke v.<org.apache.drill.metastore.mongo.transform.OutputDataTransformer: java.util.List execute()>();
return v;
}
}