public class org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema extends org.apache.drill.exec.store.AbstractSchema
{
private final java.util.Map schemas;
private final org.apache.drill.exec.store.StoragePlugin plugin;
private final org.apache.calcite.schema.SchemaFactory schemaFactory;
private final org.apache.calcite.schema.SchemaPlus parent;
private final java.lang.String parentName;
private final java.util.Map configMap;
public void <init>(java.lang.String, org.apache.drill.exec.store.StoragePlugin, org.apache.calcite.schema.SchemaFactory, org.apache.calcite.schema.SchemaPlus, java.lang.String, java.util.Map)
{
org.apache.calcite.schema.SchemaFactory v;
org.apache.calcite.schema.SchemaPlus v;
org.apache.drill.exec.store.StoragePlugin v;
java.util.concurrent.ConcurrentHashMap v;
org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema v;
java.util.List v;
java.util.Map v;
java.lang.String v, v;
v := @this: org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema;
v := @parameter: java.lang.String;
v := @parameter: org.apache.drill.exec.store.StoragePlugin;
v := @parameter: org.apache.calcite.schema.SchemaFactory;
v := @parameter: org.apache.calcite.schema.SchemaPlus;
v := @parameter: java.lang.String;
v := @parameter: java.util.Map;
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.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v.<org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema: java.util.Map schemas> = v;
v.<org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema: org.apache.drill.exec.store.StoragePlugin plugin> = v;
v.<org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema: org.apache.calcite.schema.SchemaFactory schemaFactory> = v;
v.<org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema: org.apache.calcite.schema.SchemaPlus parent> = v;
v.<org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema: java.lang.String parentName> = v;
v.<org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema: java.util.Map configMap> = v;
return;
}
public java.lang.String getTypeName()
{
org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema v;
v := @this: org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema;
return "cassandra";
}
public org.apache.calcite.schema.Schema getSubSchema(java.lang.String)
{
java.util.Map v;
java.lang.Object v;
java.lang.String v;
org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema v;
java.util.function.Function v;
v := @this: org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema;
v := @parameter: java.lang.String;
v = v.<org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema: java.util.Map schemas>;
v = staticinvoke <org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema$createSubSchema__14: java.util.function.Function bootstrap$(org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object computeIfAbsent(java.lang.Object,java.util.function.Function)>(v, v);
return v;
}
public org.apache.calcite.schema.Schema createSubSchema(java.lang.String)
{
org.apache.calcite.schema.SchemaFactory v;
org.apache.calcite.schema.SchemaPlus v, v;
org.apache.drill.exec.store.StoragePlugin v;
java.util.HashMap v;
org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema v;
org.apache.drill.exec.store.cassandra.schema.CassandraDrillSchema v;
java.util.Map v;
org.apache.calcite.schema.Schema v;
java.lang.String v, v;
v := @this: org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema;
v := @parameter: java.lang.String;
v = new java.util.HashMap;
v = v.<org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema: java.util.Map configMap>;
specialinvoke v.<java.util.HashMap: void <init>(java.util.Map)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("keyspace", v);
v = v.<org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema: org.apache.calcite.schema.SchemaPlus parent>;
v = v.<org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema: java.lang.String parentName>;
v = interfaceinvoke v.<org.apache.calcite.schema.SchemaPlus: org.apache.calcite.schema.SchemaPlus getSubSchema(java.lang.String)>(v);
v = new org.apache.drill.exec.store.cassandra.schema.CassandraDrillSchema;
v = v.<org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema: org.apache.drill.exec.store.StoragePlugin plugin>;
v = v.<org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema: org.apache.calcite.schema.SchemaFactory schemaFactory>;
v = interfaceinvoke v.<org.apache.calcite.schema.SchemaFactory: org.apache.calcite.schema.Schema create(org.apache.calcite.schema.SchemaPlus,java.lang.String,java.util.Map)>(v, v, v);
specialinvoke v.<org.apache.drill.exec.store.cassandra.schema.CassandraDrillSchema: void <init>(java.lang.String,org.apache.drill.exec.store.StoragePlugin,org.apache.calcite.adapter.cassandra.CassandraSchema)>(v, v, v);
interfaceinvoke v.<org.apache.calcite.schema.SchemaPlus: org.apache.calcite.schema.SchemaPlus add(java.lang.String,org.apache.calcite.schema.Schema)>(v, v);
return v;
}
public org.apache.calcite.linq4j.tree.Expression getExpression(org.apache.calcite.schema.SchemaPlus, java.lang.String)
{
org.apache.calcite.schema.SchemaPlus v;
org.apache.calcite.linq4j.tree.MethodCallExpression v;
org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema v;
java.lang.String v;
org.apache.calcite.util.BuiltInMethod v;
org.apache.calcite.linq4j.tree.ParameterExpression v;
java.lang.reflect.Method v;
org.apache.calcite.linq4j.tree.Expression[] v;
v := @this: org.apache.drill.exec.store.cassandra.schema.CassandraRootDrillSchema;
v := @parameter: org.apache.calcite.schema.SchemaPlus;
v := @parameter: java.lang.String;
v = <org.apache.calcite.DataContext: org.apache.calcite.linq4j.tree.ParameterExpression ROOT>;
v = <org.apache.calcite.util.BuiltInMethod: org.apache.calcite.util.BuiltInMethod DATA_CONTEXT_GET_ROOT_SCHEMA>;
v = v.<org.apache.calcite.util.BuiltInMethod: java.lang.reflect.Method method>;
v = newarray (org.apache.calcite.linq4j.tree.Expression)[0];
v = staticinvoke <org.apache.calcite.linq4j.tree.Expressions: org.apache.calcite.linq4j.tree.MethodCallExpression call(org.apache.calcite.linq4j.tree.Expression,java.lang.reflect.Method,org.apache.calcite.linq4j.tree.Expression[])>(v, v, v);
return v;
}
}