public class org.apache.drill.exec.store.jdbc.DrillJdbcConvention extends org.apache.calcite.adapter.jdbc.JdbcConvention
{
private static final java.util.Set EXCLUDED_CALCITE_RULES;
private final org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet rules;
private final org.apache.drill.exec.store.jdbc.JdbcStoragePlugin plugin;
void <init>(org.apache.calcite.sql.SqlDialect, java.lang.String, org.apache.drill.exec.store.jdbc.JdbcStoragePlugin, org.apache.drill.exec.proto.UserBitShared$UserCredentials)
{
org.apache.calcite.plan.Convention v, v;
org.apache.drill.exec.proto.UserBitShared$UserCredentials v;
org.apache.drill.exec.store.jdbc.JdbcStoragePlugin v;
org.apache.drill.exec.store.jdbc.DrillJdbcConvention v;
boolean v;
org.apache.drill.exec.store.jdbc.JdbcIntermediatePrelConverterRule v;
java.util.function.Predicate v;
java.util.List v, v;
java.util.stream.Stream v, v;
org.apache.drill.exec.store.enumerable.plan.DrillJdbcRuleBase$DrillJdbcProjectRule v;
org.apache.drill.exec.store.jdbc.rules.JdbcLimitRule v;
java.lang.Object[] v;
org.apache.drill.exec.store.enumerable.plan.DrillJdbcRuleBase$DrillJdbcFilterRule v;
org.apache.drill.exec.store.jdbc.rules.JdbcSortRule v;
java.lang.String v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder v, v, v, v, v, v, v, v;
java.util.Iterator v;
org.apache.calcite.linq4j.tree.ConstantExpression v;
org.apache.calcite.sql.SqlDialect v;
java.util.function.Consumer v;
org.apache.calcite.plan.RelOptRule v, v, v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet v;
java.lang.Object v;
v := @this: org.apache.drill.exec.store.jdbc.DrillJdbcConvention;
v := @parameter: org.apache.calcite.sql.SqlDialect;
v := @parameter: java.lang.String;
v := @parameter: org.apache.drill.exec.store.jdbc.JdbcStoragePlugin;
v := @parameter: org.apache.drill.exec.proto.UserBitShared$UserCredentials;
v = <org.apache.calcite.linq4j.tree.ConstantUntypedNull: org.apache.calcite.linq4j.tree.ConstantExpression INSTANCE>;
specialinvoke v.<org.apache.calcite.adapter.jdbc.JdbcConvention: void <init>(org.apache.calcite.sql.SqlDialect,org.apache.calcite.linq4j.tree.Expression,java.lang.String)>(v, v, v);
v.<org.apache.drill.exec.store.jdbc.DrillJdbcConvention: org.apache.drill.exec.store.jdbc.JdbcStoragePlugin plugin> = v;
v = newarray (org.apache.calcite.plan.RelTrait)[2];
v = <org.apache.calcite.plan.Convention: org.apache.calcite.plan.Convention NONE>;
v[0] = v;
v = <org.apache.drill.exec.planner.logical.DrillRel: org.apache.calcite.plan.Convention DRILL_LOGICAL>;
v[1] = v;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder builder()>();
v = new org.apache.drill.exec.store.jdbc.JdbcIntermediatePrelConverterRule;
specialinvoke v.<org.apache.drill.exec.store.jdbc.JdbcIntermediatePrelConverterRule: void <init>(org.apache.calcite.adapter.jdbc.JdbcConvention,org.apache.drill.exec.proto.UserBitShared$UserCredentials)>(v, v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder add(java.lang.Object)>(v);
v = staticinvoke <org.apache.drill.exec.store.enumerable.plan.VertexDrelConverterRule: org.apache.calcite.plan.RelOptRule create(org.apache.calcite.plan.Convention)>(v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder add(java.lang.Object)>(v);
v = <org.apache.drill.exec.planner.RuleInstance: org.apache.calcite.plan.RelOptRule FILTER_SET_OP_TRANSPOSE_RULE>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder add(java.lang.Object)>(v);
v = <org.apache.drill.exec.planner.RuleInstance: org.apache.calcite.plan.RelOptRule PROJECT_REMOVE_RULE>;
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder add(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = new org.apache.drill.exec.store.enumerable.plan.DrillJdbcRuleBase$DrillJdbcProjectRule;
specialinvoke v.<org.apache.drill.exec.store.enumerable.plan.DrillJdbcRuleBase$DrillJdbcProjectRule: void <init>(org.apache.calcite.plan.RelTrait,org.apache.calcite.adapter.jdbc.JdbcConvention)>(v, v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder add(java.lang.Object)>(v);
v = new org.apache.drill.exec.store.enumerable.plan.DrillJdbcRuleBase$DrillJdbcFilterRule;
specialinvoke v.<org.apache.drill.exec.store.enumerable.plan.DrillJdbcRuleBase$DrillJdbcFilterRule: void <init>(org.apache.calcite.plan.RelTrait,org.apache.calcite.adapter.jdbc.JdbcConvention)>(v, v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder add(java.lang.Object)>(v);
v = new org.apache.drill.exec.store.jdbc.rules.JdbcSortRule;
specialinvoke v.<org.apache.drill.exec.store.jdbc.rules.JdbcSortRule: void <init>(org.apache.calcite.plan.RelTrait,org.apache.drill.exec.store.jdbc.DrillJdbcConvention)>(v, v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder add(java.lang.Object)>(v);
v = new org.apache.drill.exec.store.jdbc.rules.JdbcLimitRule;
specialinvoke v.<org.apache.drill.exec.store.jdbc.rules.JdbcLimitRule: void <init>(org.apache.calcite.plan.RelTrait,org.apache.drill.exec.store.jdbc.DrillJdbcConvention)>(v, v);
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder add(java.lang.Object)>(v);
v = staticinvoke <org.apache.drill.exec.store.jdbc.DrillJdbcConvention: java.util.List rules(org.apache.calcite.plan.RelTrait,org.apache.calcite.adapter.jdbc.JdbcConvention)>(v, v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.drill.exec.store.jdbc.DrillJdbcConvention$lambda_new_0__2: java.util.function.Predicate bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(v);
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.apache.drill.exec.store.jdbc.DrillJdbcConvention$add__3: java.util.function.Consumer bootstrap$(org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder)>(v);
interfaceinvoke v.<java.util.stream.Stream: void forEach(java.util.function.Consumer)>(v);
goto label;
label:
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet build()>();
v.<org.apache.drill.exec.store.jdbc.DrillJdbcConvention: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet rules> = v;
return;
}
public void register(org.apache.calcite.plan.RelOptPlanner)
{
java.util.function.Consumer v;
org.apache.drill.exec.store.jdbc.DrillJdbcConvention v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet v;
org.apache.calcite.plan.RelOptPlanner v;
v := @this: org.apache.drill.exec.store.jdbc.DrillJdbcConvention;
v := @parameter: org.apache.calcite.plan.RelOptPlanner;
v = v.<org.apache.drill.exec.store.jdbc.DrillJdbcConvention: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet rules>;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.apache.drill.exec.store.jdbc.DrillJdbcConvention$addRule__4: java.util.function.Consumer bootstrap$(org.apache.calcite.plan.RelOptPlanner)>(v);
virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: void forEach(java.util.function.Consumer)>(v);
return;
}
public java.util.Set getRules()
{
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet v;
org.apache.drill.exec.store.jdbc.DrillJdbcConvention v;
v := @this: org.apache.drill.exec.store.jdbc.DrillJdbcConvention;
v = v.<org.apache.drill.exec.store.jdbc.DrillJdbcConvention: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet rules>;
return v;
}
public org.apache.drill.exec.store.jdbc.JdbcStoragePlugin getPlugin()
{
org.apache.drill.exec.store.jdbc.JdbcStoragePlugin v;
org.apache.drill.exec.store.jdbc.DrillJdbcConvention v;
v := @this: org.apache.drill.exec.store.jdbc.DrillJdbcConvention;
v = v.<org.apache.drill.exec.store.jdbc.DrillJdbcConvention: org.apache.drill.exec.store.jdbc.JdbcStoragePlugin plugin>;
return v;
}
private static java.util.List rules(org.apache.calcite.plan.RelTrait, org.apache.calcite.adapter.jdbc.JdbcConvention)
{
java.util.function.Consumer v;
org.apache.calcite.adapter.jdbc.JdbcConvention v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList$Builder v;
org.apache.calcite.plan.RelTrait v;
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList v;
v := @parameter: org.apache.calcite.plan.RelTrait;
v := @parameter: org.apache.calcite.adapter.jdbc.JdbcConvention;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList$Builder builder()>();
v = staticinvoke <org.apache.drill.exec.store.jdbc.DrillJdbcConvention$lambda_rules_1__5: java.util.function.Consumer bootstrap$(org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList$Builder,org.apache.calcite.plan.RelTrait,org.apache.calcite.adapter.jdbc.JdbcConvention)>(v, v, v);
staticinvoke <org.apache.drill.exec.store.jdbc.DrillJdbcConvention: void foreachRule(org.apache.calcite.adapter.jdbc.JdbcConvention,java.util.function.Consumer)>(v, v);
v = virtualinvoke v.<org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList$Builder: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList build()>();
return v;
}
private static void foreachRule(org.apache.calcite.adapter.jdbc.JdbcConvention, java.util.function.Consumer)
{
org.apache.calcite.adapter.jdbc.JdbcRules$JdbcIntersectRule v;
org.apache.calcite.adapter.jdbc.JdbcRules$JdbcUnionRule v;
org.apache.calcite.adapter.jdbc.JdbcRules$JdbcTableModificationRule v;
org.apache.calcite.adapter.jdbc.JdbcRules$JdbcValuesRule v;
java.util.function.Consumer v;
org.apache.calcite.adapter.jdbc.JdbcRules$JdbcJoinRule v;
org.apache.calcite.adapter.jdbc.JdbcConvention v;
org.apache.calcite.adapter.jdbc.JdbcRules$JdbcAggregateRule v;
org.apache.calcite.adapter.jdbc.JdbcToEnumerableConverterRule v;
org.apache.calcite.adapter.jdbc.JdbcRules$JdbcSortRule v;
org.apache.calcite.adapter.jdbc.JdbcRules$JdbcProjectRule v;
org.apache.calcite.adapter.jdbc.JdbcRules$JdbcMinusRule v;
org.apache.calcite.adapter.jdbc.JdbcRules$JdbcFilterRule v;
v := @parameter: org.apache.calcite.adapter.jdbc.JdbcConvention;
v := @parameter: java.util.function.Consumer;
v = staticinvoke <org.apache.calcite.adapter.jdbc.JdbcToEnumerableConverterRule: org.apache.calcite.adapter.jdbc.JdbcToEnumerableConverterRule create(org.apache.calcite.adapter.jdbc.JdbcConvention)>(v);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
v = staticinvoke <org.apache.calcite.adapter.jdbc.JdbcRules$JdbcJoinRule: org.apache.calcite.adapter.jdbc.JdbcRules$JdbcJoinRule create(org.apache.calcite.adapter.jdbc.JdbcConvention)>(v);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
v = staticinvoke <org.apache.calcite.adapter.jdbc.JdbcRules$JdbcProjectRule: org.apache.calcite.adapter.jdbc.JdbcRules$JdbcProjectRule create(org.apache.calcite.adapter.jdbc.JdbcConvention)>(v);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
v = staticinvoke <org.apache.calcite.adapter.jdbc.JdbcRules$JdbcFilterRule: org.apache.calcite.adapter.jdbc.JdbcRules$JdbcFilterRule create(org.apache.calcite.adapter.jdbc.JdbcConvention)>(v);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
v = staticinvoke <org.apache.calcite.adapter.jdbc.JdbcRules$JdbcAggregateRule: org.apache.calcite.adapter.jdbc.JdbcRules$JdbcAggregateRule create(org.apache.calcite.adapter.jdbc.JdbcConvention)>(v);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
v = staticinvoke <org.apache.calcite.adapter.jdbc.JdbcRules$JdbcSortRule: org.apache.calcite.adapter.jdbc.JdbcRules$JdbcSortRule create(org.apache.calcite.adapter.jdbc.JdbcConvention)>(v);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
v = staticinvoke <org.apache.calcite.adapter.jdbc.JdbcRules$JdbcUnionRule: org.apache.calcite.adapter.jdbc.JdbcRules$JdbcUnionRule create(org.apache.calcite.adapter.jdbc.JdbcConvention)>(v);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
v = staticinvoke <org.apache.calcite.adapter.jdbc.JdbcRules$JdbcIntersectRule: org.apache.calcite.adapter.jdbc.JdbcRules$JdbcIntersectRule create(org.apache.calcite.adapter.jdbc.JdbcConvention)>(v);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
v = staticinvoke <org.apache.calcite.adapter.jdbc.JdbcRules$JdbcMinusRule: org.apache.calcite.adapter.jdbc.JdbcRules$JdbcMinusRule create(org.apache.calcite.adapter.jdbc.JdbcConvention)>(v);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
v = staticinvoke <org.apache.calcite.adapter.jdbc.JdbcRules$JdbcTableModificationRule: org.apache.calcite.adapter.jdbc.JdbcRules$JdbcTableModificationRule create(org.apache.calcite.adapter.jdbc.JdbcConvention)>(v);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
v = staticinvoke <org.apache.calcite.adapter.jdbc.JdbcRules$JdbcValuesRule: org.apache.calcite.adapter.jdbc.JdbcRules$JdbcValuesRule create(org.apache.calcite.adapter.jdbc.JdbcConvention)>(v);
interfaceinvoke v.<java.util.function.Consumer: void accept(java.lang.Object)>(v);
return;
}
static void <clinit>()
{
org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet v;
v = staticinvoke <org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet: org.apache.drill.shaded.guava.com.google.common.collect.ImmutableSet of(java.lang.Object,java.lang.Object,java.lang.Object,java.lang.Object)>(class "Lorg/apache/calcite/adapter/jdbc/JdbcToEnumerableConverterRule;", class "Lorg/apache/calcite/adapter/jdbc/JdbcRules$JdbcFilterRule;", class "Lorg/apache/calcite/adapter/jdbc/JdbcRules$JdbcProjectRule;", class "Lorg/apache/calcite/adapter/jdbc/JdbcRules$JdbcSortRule;");
<org.apache.drill.exec.store.jdbc.DrillJdbcConvention: java.util.Set EXCLUDED_CALCITE_RULES> = v;
return;
}
}