public class org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema extends org.apache.drill.exec.store.AbstractSchema
{
private final org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin plugin;
private final java.util.Map schemaMap;
private final java.util.Map drillTables;
private final java.lang.String userName;
public void <init>(org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin, java.lang.String, java.lang.String)
{
java.util.HashMap v, v;
java.util.function.Function v, v, v;
org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin v;
java.lang.String v, v, v;
org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema v;
java.util.function.Consumer v;
java.util.List v, v;
java.util.stream.Stream v, v, v, v;
java.util.Optional v;
java.lang.Object v;
v := @this: org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema;
v := @parameter: org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
specialinvoke v.<org.apache.drill.exec.store.AbstractSchema: void <init>(java.util.List,java.lang.String)>(v, v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.Map schemaMap> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.Map drillTables> = v;
v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin plugin> = v;
v = staticinvoke <java.util.Optional: java.util.Optional ofNullable(java.lang.Object)>(v);
v = staticinvoke <org.apache.drill.exec.util.ImpersonationUtil: java.lang.String getProcessUserName()>();
v = virtualinvoke v.<java.util.Optional: java.lang.Object orElse(java.lang.Object)>(v);
v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.lang.String userName> = v;
v = specialinvoke v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.List getSchemasList()>();
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema$getSchemaName__9: 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.exec.store.drill.plugin.schema.DrillPluginSchema$toLowerCase__10: 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.exec.store.drill.plugin.schema.DrillPluginSchema$parseFromString__11: 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.exec.store.drill.plugin.schema.DrillPluginSchema$addSubSchema__12: java.util.function.Consumer bootstrap$(org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema)>(v);
interfaceinvoke v.<java.util.stream.Stream: void forEach(java.util.function.Consumer)>(v);
return;
}
private void <init>(org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin, java.util.List, java.lang.String, java.lang.String)
{
java.util.List v;
org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema v;
org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin v;
java.util.HashMap v, v;
java.lang.String v, v;
v := @this: org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema;
v := @parameter: org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin;
v := @parameter: java.util.List;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
specialinvoke v.<org.apache.drill.exec.store.AbstractSchema: void <init>(java.util.List,java.lang.String)>(v, v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.Map schemaMap> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.Map drillTables> = v;
v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin plugin> = v;
v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.lang.String userName> = v;
return;
}
public void addSubSchema(org.apache.drill.common.expression.SchemaPath)
{
org.apache.drill.common.expression.PathSegment v;
org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin v, v;
java.util.Map v, v;
java.lang.String v, v, v, v, v, v;
boolean v;
org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema v, v, v, v;
org.apache.drill.common.expression.SchemaPath v, v;
java.util.List v, v;
org.apache.drill.common.expression.PathSegment$NameSegment v, v;
v := @this: org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema;
v := @parameter: org.apache.drill.common.expression.SchemaPath;
v = new org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema;
v = v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin plugin>;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.List getSchemaPath()>();
v = virtualinvoke v.<org.apache.drill.common.expression.SchemaPath: java.lang.String getRootSegmentPath()>();
v = v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.lang.String userName>;
specialinvoke v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: void <init>(org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin,java.util.List,java.lang.String,java.lang.String)>(v, v, v, v);
v = v;
v = v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.Map schemaMap>;
v = virtualinvoke v.<org.apache.drill.common.expression.SchemaPath: java.lang.String getRootSegmentPath()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
v = virtualinvoke v.<org.apache.drill.common.expression.SchemaPath: boolean isLeaf()>();
if v != 0 goto label;
v = new org.apache.drill.common.expression.SchemaPath;
v = virtualinvoke v.<org.apache.drill.common.expression.SchemaPath: org.apache.drill.common.expression.PathSegment$NameSegment getRootSegment()>();
v = virtualinvoke v.<org.apache.drill.common.expression.PathSegment$NameSegment: org.apache.drill.common.expression.PathSegment getChild()>();
v = virtualinvoke v.<org.apache.drill.common.expression.PathSegment: org.apache.drill.common.expression.PathSegment$NameSegment getNameSegment()>();
specialinvoke v.<org.apache.drill.common.expression.SchemaPath: void <init>(org.apache.drill.common.expression.PathSegment$NameSegment)>(v);
v = v;
v = new org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema;
v = v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin plugin>;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.List getSchemaPath()>();
v = virtualinvoke v.<org.apache.drill.common.expression.SchemaPath: java.lang.String getRootSegmentPath()>();
v = v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.lang.String userName>;
specialinvoke v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: void <init>(org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin,java.util.List,java.lang.String,java.lang.String)>(v, v, v, v);
v = v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.Map schemaMap>;
v = virtualinvoke v.<org.apache.drill.common.expression.SchemaPath: java.lang.String getRootSegmentPath()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v;
goto label;
label:
return;
}
private java.util.List getSchemasList()
{
org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema v;
org.apache.drill.common.exceptions.DrillRuntimeException v;
java.lang.Exception v;
org.apache.drill.exec.rpc.DrillRpcFuture v;
java.util.List v;
org.apache.drill.exec.client.DrillClient v;
org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema;
label:
v = v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin plugin>;
v = v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.lang.String userName>;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin: org.apache.drill.exec.client.DrillClient getClient(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.drill.exec.client.DrillClient: org.apache.drill.exec.rpc.DrillRpcFuture getSchemas(org.apache.drill.exec.proto.UserProtos$LikeFilter,org.apache.drill.exec.proto.UserProtos$LikeFilter)>(null, null);
v = interfaceinvoke v.<org.apache.drill.exec.rpc.DrillRpcFuture: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.drill.exec.proto.UserProtos$GetSchemasResp: java.util.List getSchemasList()>();
label:
return v;
label:
v := @caughtexception;
v = new org.apache.drill.common.exceptions.DrillRuntimeException;
specialinvoke v.<org.apache.drill.common.exceptions.DrillRuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.lang.InterruptedException from label to label with label;
catch java.util.concurrent.ExecutionException from label to label with label;
}
public org.apache.drill.exec.store.AbstractSchema getSubSchema(java.lang.String)
{
org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema v;
java.util.Map v;
java.lang.Object v;
java.lang.String v;
v := @this: org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema;
v := @parameter: java.lang.String;
v = v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.Map schemaMap>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
void setHolder(org.apache.calcite.schema.SchemaPlus)
{
java.util.function.Consumer v;
org.apache.calcite.schema.SchemaPlus v;
org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema v;
java.util.Set v;
v := @this: org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema;
v := @parameter: org.apache.calcite.schema.SchemaPlus;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.Set getSubSchemaNames()>();
v = staticinvoke <org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema$lambda_setHolder_0__13: java.util.function.Consumer bootstrap$(org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema,org.apache.calcite.schema.SchemaPlus)>(v, v);
interfaceinvoke v.<java.util.Set: void forEach(java.util.function.Consumer)>(v);
return;
}
public boolean showInInformationSchema()
{
org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema v;
v := @this: org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema;
return 1;
}
public java.util.Set getSubSchemaNames()
{
java.util.Set v;
org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema v;
java.util.Map v;
v := @this: org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema;
v = v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.Map schemaMap>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
return v;
}
public org.apache.calcite.schema.Table getTable(java.lang.String)
{
org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema v;
java.util.Map v;
java.lang.Object v;
java.lang.String v;
java.util.function.Function v;
v := @this: org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema;
v := @parameter: java.lang.String;
v = v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.Map drillTables>;
v = staticinvoke <org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema$lambda_getTable_1__14: java.util.function.Function bootstrap$(org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object computeIfAbsent(java.lang.Object,java.util.function.Function)>(v, v);
return v;
}
public java.lang.String getTypeName()
{
org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema v;
v := @this: org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema;
return "drill";
}
public java.util.Set getTableNames()
{
java.lang.Object[] v;
java.lang.String[] v;
org.apache.drill.common.exceptions.DrillRuntimeException v;
java.util.function.Function v;
org.apache.drill.exec.proto.UserProtos$LikeFilter$Builder v, v;
org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin v;
int v;
java.lang.String v, v;
java.util.stream.Collector v;
org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema v;
org.apache.drill.common.expression.SchemaPath v;
java.lang.Exception v;
org.apache.drill.exec.proto.UserProtos$LikeFilter v;
org.apache.drill.exec.rpc.DrillRpcFuture v;
java.util.List v, v, v;
java.util.stream.Stream v, v;
org.apache.drill.exec.client.DrillClient v;
java.lang.Object v, v;
v := @this: org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema;
label:
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.util.List getSchemaPath()>();
v = interfaceinvoke v.<java.util.List: int size()>();
v = interfaceinvoke v.<java.util.List: java.util.List subList(int,int)>(1, v);
v = newarray (java.lang.String)[0];
v = interfaceinvoke v.<java.util.List: java.lang.Object[] toArray(java.lang.Object[])>(v);
v = staticinvoke <org.apache.drill.common.expression.SchemaPath: org.apache.drill.common.expression.SchemaPath getCompoundPath(java.lang.String[])>(v);
v = virtualinvoke v.<org.apache.drill.common.expression.SchemaPath: java.lang.String getAsUnescapedPath()>();
v = staticinvoke <org.apache.drill.exec.proto.UserProtos$LikeFilter: org.apache.drill.exec.proto.UserProtos$LikeFilter$Builder newBuilder()>();
v = virtualinvoke v.<org.apache.drill.exec.proto.UserProtos$LikeFilter$Builder: org.apache.drill.exec.proto.UserProtos$LikeFilter$Builder setPattern(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.drill.exec.proto.UserProtos$LikeFilter$Builder: org.apache.drill.exec.proto.UserProtos$LikeFilter build()>();
v = v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin plugin>;
v = v.<org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema: java.lang.String userName>;
v = virtualinvoke v.<org.apache.drill.exec.store.drill.plugin.DrillStoragePlugin: org.apache.drill.exec.client.DrillClient getClient(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.drill.exec.client.DrillClient: org.apache.drill.exec.rpc.DrillRpcFuture getTables(org.apache.drill.exec.proto.UserProtos$LikeFilter,org.apache.drill.exec.proto.UserProtos$LikeFilter,org.apache.drill.exec.proto.UserProtos$LikeFilter,java.util.List)>(null, v, null, null);
v = interfaceinvoke v.<org.apache.drill.exec.rpc.DrillRpcFuture: java.lang.Object get()>();
v = virtualinvoke v.<org.apache.drill.exec.proto.UserProtos$GetTablesResp: java.util.List getTablesList()>();
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.drill.exec.store.drill.plugin.schema.DrillPluginSchema$getTableName__15: 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 toSet()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.drill.common.exceptions.DrillRuntimeException;
specialinvoke v.<org.apache.drill.common.exceptions.DrillRuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.lang.InterruptedException from label to label with label;
catch java.util.concurrent.ExecutionException from label to label with label;
}
}