public class org.apache.calcite.adapter.cassandra.CalciteUtils extends java.lang.Object
{
private static final org.apache.calcite.plan.RelOptRule VERTEX_DREL_CONVERTER_RULE;
private static final org.apache.calcite.plan.RelOptRule ENUMERABLE_INTERMEDIATE_PREL_CONVERTER_RULE;
public void <init>()
{
org.apache.calcite.adapter.cassandra.CalciteUtils v;
v := @this: org.apache.calcite.adapter.cassandra.CalciteUtils;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static org.apache.calcite.adapter.cassandra.CassandraTableScan tableScanCreator(org.apache.calcite.plan.RelOptCluster, org.apache.calcite.plan.RelTraitSet, org.apache.calcite.plan.RelOptTable, org.apache.calcite.adapter.cassandra.CassandraTable, org.apache.calcite.rel.type.RelDataType)
{
org.apache.calcite.plan.RelOptCluster v;
org.apache.calcite.rel.type.RelDataType v;
org.apache.calcite.adapter.cassandra.CassandraTable v;
org.apache.calcite.adapter.cassandra.CassandraTableScan v;
org.apache.calcite.plan.RelOptTable v;
org.apache.calcite.plan.RelTraitSet v;
v := @parameter: org.apache.calcite.plan.RelOptCluster;
v := @parameter: org.apache.calcite.plan.RelTraitSet;
v := @parameter: org.apache.calcite.plan.RelOptTable;
v := @parameter: org.apache.calcite.adapter.cassandra.CassandraTable;
v := @parameter: org.apache.calcite.rel.type.RelDataType;
v = new org.apache.calcite.adapter.cassandra.CassandraTableScan;
specialinvoke v.<org.apache.calcite.adapter.cassandra.CassandraTableScan: void <init>(org.apache.calcite.plan.RelOptCluster,org.apache.calcite.plan.RelTraitSet,org.apache.calcite.plan.RelOptTable,org.apache.calcite.adapter.cassandra.CassandraTable,org.apache.calcite.rel.type.RelDataType)>(v, v, v, v, v);
return v;
}
public static java.util.Set cassandraRules()
{
org.apache.calcite.plan.RelOptRule v, v;
java.util.stream.Stream v;
org.apache.drill.exec.store.cassandra.plan.DrillCassandraLimitRule v;
org.apache.calcite.plan.RelOptRule[] v;
java.lang.Object v;
java.util.stream.Collector v;
v = <org.apache.calcite.adapter.cassandra.CassandraRules: org.apache.calcite.plan.RelOptRule[] RULES>;
v = staticinvoke <java.util.Arrays: java.util.stream.Stream stream(java.lang.Object[])>(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);
v = <org.apache.drill.exec.store.cassandra.plan.DrillCassandraLimitRule: org.apache.drill.exec.store.cassandra.plan.DrillCassandraLimitRule INSTANCE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.calcite.adapter.cassandra.CalciteUtils: org.apache.calcite.plan.RelOptRule ENUMERABLE_INTERMEDIATE_PREL_CONVERTER_RULE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.calcite.adapter.cassandra.CalciteUtils: org.apache.calcite.plan.RelOptRule VERTEX_DREL_CONVERTER_RULE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
return v;
}
public static com.datastax.oss.driver.api.core.CqlSession getSession(org.apache.calcite.schema.SchemaPlus)
{
org.apache.calcite.adapter.cassandra.CassandraSchema v;
org.apache.calcite.schema.SchemaPlus v;
com.datastax.oss.driver.api.core.CqlSession v;
java.lang.Object v;
v := @parameter: org.apache.calcite.schema.SchemaPlus;
v = interfaceinvoke v.<org.apache.calcite.schema.SchemaPlus: java.lang.Object unwrap(java.lang.Class)>(class "Lorg/apache/drill/exec/store/cassandra/schema/CassandraDrillSchema;");
v = virtualinvoke v.<org.apache.drill.exec.store.cassandra.schema.CassandraDrillSchema: org.apache.calcite.adapter.cassandra.CassandraSchema getDelegatingSchema()>();
v = v.<org.apache.calcite.adapter.cassandra.CassandraSchema: com.datastax.oss.driver.api.core.CqlSession session>;
return v;
}
static void <clinit>()
{
org.apache.calcite.plan.Convention v, v;
org.apache.drill.exec.store.enumerable.plan.EnumerableIntermediatePrelConverterRule v;
org.apache.calcite.plan.RelOptRule v;
org.apache.drill.exec.store.cassandra.plan.CassandraEnumerablePrelContext v;
v = <org.apache.calcite.adapter.cassandra.CassandraRel: org.apache.calcite.plan.Convention CONVENTION>;
v = staticinvoke <org.apache.drill.exec.store.enumerable.plan.VertexDrelConverterRule: org.apache.calcite.plan.RelOptRule create(org.apache.calcite.plan.Convention)>(v);
<org.apache.calcite.adapter.cassandra.CalciteUtils: org.apache.calcite.plan.RelOptRule VERTEX_DREL_CONVERTER_RULE> = v;
v = new org.apache.drill.exec.store.enumerable.plan.EnumerableIntermediatePrelConverterRule;
v = new org.apache.drill.exec.store.cassandra.plan.CassandraEnumerablePrelContext;
specialinvoke v.<org.apache.drill.exec.store.cassandra.plan.CassandraEnumerablePrelContext: void <init>(java.lang.String)>("cassandra");
v = <org.apache.calcite.adapter.cassandra.CassandraRel: org.apache.calcite.plan.Convention CONVENTION>;
specialinvoke v.<org.apache.drill.exec.store.enumerable.plan.EnumerableIntermediatePrelConverterRule: void <init>(org.apache.drill.exec.store.enumerable.plan.EnumerablePrelContext,org.apache.calcite.plan.Convention)>(v, v);
<org.apache.calcite.adapter.cassandra.CalciteUtils: org.apache.calcite.plan.RelOptRule ENUMERABLE_INTERMEDIATE_PREL_CONVERTER_RULE> = v;
return;
}
}