public class org.apache.calcite.adapter.elasticsearch.CalciteUtils extends java.lang.Object
{
private static final java.util.List BANNED_RULES;
public static final java.util.function.Predicate RULE_PREDICATE;
public static final org.apache.calcite.plan.RelOptRule ELASTIC_DREL_CONVERTER_RULE;
public static final org.apache.calcite.plan.RelOptRule ENUMERABLE_INTERMEDIATE_PREL_CONVERTER_RULE;
public void <init>()
{
org.apache.calcite.adapter.elasticsearch.CalciteUtils v;
v := @this: org.apache.calcite.adapter.elasticsearch.CalciteUtils;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static java.util.Set elasticSearchRules()
{
java.util.function.Predicate v;
org.apache.calcite.plan.RelOptRule[] v;
org.apache.drill.exec.store.elasticsearch.plan.ElasticsearchProjectRule v;
org.apache.calcite.plan.RelOptRule v, v;
java.util.stream.Stream v, v;
org.apache.drill.exec.store.elasticsearch.plan.ElasticsearchFilterRule v;
java.lang.Object v;
java.util.stream.Collector v;
v = <org.apache.calcite.adapter.elasticsearch.ElasticsearchRules: org.apache.calcite.plan.RelOptRule[] RULES>;
v = staticinvoke <java.util.Arrays: java.util.stream.Stream stream(java.lang.Object[])>(v);
v = <org.apache.calcite.adapter.elasticsearch.CalciteUtils: java.util.function.Predicate RULE_PREDICATE>;
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream filter(java.util.function.Predicate)>(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.calcite.adapter.elasticsearch.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.elasticsearch.CalciteUtils: org.apache.calcite.plan.RelOptRule ELASTIC_DREL_CONVERTER_RULE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.drill.exec.store.elasticsearch.plan.ElasticsearchProjectRule: org.apache.drill.exec.store.elasticsearch.plan.ElasticsearchProjectRule INSTANCE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = <org.apache.drill.exec.store.elasticsearch.plan.ElasticsearchFilterRule: org.apache.drill.exec.store.elasticsearch.plan.ElasticsearchFilterRule INSTANCE>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
return v;
}
public static org.apache.calcite.rel.convert.ConverterRule getElasticsearchToEnumerableConverterRule()
{
org.apache.calcite.rel.convert.ConverterRule v;
v = <org.apache.calcite.adapter.elasticsearch.ElasticsearchToEnumerableConverterRule: org.apache.calcite.rel.convert.ConverterRule INSTANCE>;
return v;
}
public static org.apache.calcite.adapter.elasticsearch.ElasticsearchProject createProject(org.apache.calcite.plan.RelTraitSet, org.apache.calcite.rel.RelNode, java.util.List, org.apache.calcite.rel.type.RelDataType)
{
org.apache.calcite.plan.RelOptCluster v;
org.apache.calcite.adapter.elasticsearch.ElasticsearchProject v;
org.apache.calcite.rel.type.RelDataType v;
java.util.List v;
org.apache.calcite.rel.RelNode v;
org.apache.calcite.plan.RelTraitSet v;
v := @parameter: org.apache.calcite.plan.RelTraitSet;
v := @parameter: org.apache.calcite.rel.RelNode;
v := @parameter: java.util.List;
v := @parameter: org.apache.calcite.rel.type.RelDataType;
v = new org.apache.calcite.adapter.elasticsearch.ElasticsearchProject;
v = interfaceinvoke v.<org.apache.calcite.rel.RelNode: org.apache.calcite.plan.RelOptCluster getCluster()>();
specialinvoke v.<org.apache.calcite.adapter.elasticsearch.ElasticsearchProject: void <init>(org.apache.calcite.plan.RelOptCluster,org.apache.calcite.plan.RelTraitSet,org.apache.calcite.rel.RelNode,java.util.List,org.apache.calcite.rel.type.RelDataType)>(v, v, v, v, v);
return v;
}
public static org.apache.calcite.adapter.elasticsearch.ElasticsearchFilter createFilter(org.apache.calcite.plan.RelTraitSet, org.apache.calcite.rel.RelNode, org.apache.calcite.rex.RexNode)
{
org.apache.calcite.plan.RelOptCluster v;
org.apache.calcite.adapter.elasticsearch.ElasticsearchFilter v;
org.apache.calcite.rex.RexNode v;
org.apache.calcite.rel.RelNode v;
org.apache.calcite.plan.RelTraitSet v;
v := @parameter: org.apache.calcite.plan.RelTraitSet;
v := @parameter: org.apache.calcite.rel.RelNode;
v := @parameter: org.apache.calcite.rex.RexNode;
v = new org.apache.calcite.adapter.elasticsearch.ElasticsearchFilter;
v = interfaceinvoke v.<org.apache.calcite.rel.RelNode: org.apache.calcite.plan.RelOptCluster getCluster()>();
specialinvoke v.<org.apache.calcite.adapter.elasticsearch.ElasticsearchFilter: void <init>(org.apache.calcite.plan.RelOptCluster,org.apache.calcite.plan.RelTraitSet,org.apache.calcite.rel.RelNode,org.apache.calcite.rex.RexNode)>(v, v, v, v);
return v;
}
public static void analyzePredicate(org.apache.calcite.rex.RexNode) throws org.apache.calcite.adapter.elasticsearch.PredicateAnalyzer$ExpressionNotAnalyzableException
{
org.apache.calcite.rex.RexNode v;
v := @parameter: org.apache.calcite.rex.RexNode;
staticinvoke <org.apache.calcite.adapter.elasticsearch.PredicateAnalyzer: org.apache.calcite.adapter.elasticsearch.QueryBuilders$QueryBuilder analyze(org.apache.calcite.rex.RexNode)>(v);
return;
}
static void <clinit>()
{
org.apache.calcite.plan.Convention v, v;
org.apache.drill.exec.store.elasticsearch.plan.ElasticSearchEnumerablePrelContext v;
java.util.function.Predicate v;
java.lang.String[] v;
org.apache.drill.exec.store.enumerable.plan.EnumerableIntermediatePrelConverterRule v;
org.apache.calcite.plan.RelOptRule v;
java.util.List v;
v = newarray (java.lang.String)[2];
v[0] = "ElasticsearchProjectRule";
v[1] = "ElasticsearchFilterRule";
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
<org.apache.calcite.adapter.elasticsearch.CalciteUtils: java.util.List BANNED_RULES> = v;
v = staticinvoke <org.apache.calcite.adapter.elasticsearch.CalciteUtils$lambda_static_1__2: java.util.function.Predicate bootstrap$()>();
<org.apache.calcite.adapter.elasticsearch.CalciteUtils: java.util.function.Predicate RULE_PREDICATE> = v;
v = <org.apache.calcite.adapter.elasticsearch.ElasticsearchRel: 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.elasticsearch.CalciteUtils: org.apache.calcite.plan.RelOptRule ELASTIC_DREL_CONVERTER_RULE> = v;
v = new org.apache.drill.exec.store.enumerable.plan.EnumerableIntermediatePrelConverterRule;
v = new org.apache.drill.exec.store.elasticsearch.plan.ElasticSearchEnumerablePrelContext;
specialinvoke v.<org.apache.drill.exec.store.elasticsearch.plan.ElasticSearchEnumerablePrelContext: void <init>(java.lang.String)>("elastic");
v = <org.apache.calcite.adapter.elasticsearch.ElasticsearchRel: 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.elasticsearch.CalciteUtils: org.apache.calcite.plan.RelOptRule ENUMERABLE_INTERMEDIATE_PREL_CONVERTER_RULE> = v;
return;
}
}