10201

Build # 10201

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/d61dba43646d9d1e8c6a110819dbea4cae946a01">d61dba436<a href="https://github.com/apache/carbondata/commit/d61dba43646d9d1e8c6a110819dbea4cae946a01">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/349e901c8f5c8d658859089ab3acaf6377107150">349e901c8</a>">349e901c8</a><a href="https://github.com/apache/carbondata/commit/d61dba43646d9d1e8c6a110819dbea4cae946a01"> into 04b52568d">04b52568d</a>

Run Details

56601 of 77865 relevant lines covered (72.69%)

0.86 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

76.92

/integration/spark2/src/main/commonTo2.2And2.3/org/apache/spark/sql/hive/CarbonOptimizerUtil.scala

package org.apache.spark.sql.hive

import org.apache.spark.sql.CarbonDatasourceHadoopRelation
import org.apache.spark.sql.catalyst.expressions.{Exists, In, ListQuery, ScalarSubquery}
import org.apache.spark.sql.catalyst.plans.logical.{Filter, LogicalPlan}
import org.apache.spark.sql.execution.datasources.LogicalRelation

object CarbonOptimizerUtil {
  def transformForScalarSubQuery(plan: LogicalPlan): LogicalPlan = {
    // In case scalar subquery add flag in relation to skip the decoder plan in optimizer rule, And
    // optimize whole plan at once.
    val transFormedPlan = plan.transform {
      case filter: Filter =>
        filter.transformExpressions {
          case s: ScalarSubquery =>
            val tPlan = s.plan.transform {
              case lr: LogicalRelation
                if lr.relation.isInstanceOf[CarbonDatasourceHadoopRelation] =>
                lr.relation.asInstanceOf[CarbonDatasourceHadoopRelation].isSubquery += true
                lr
            }
            ScalarSubquery(tPlan, s.children, s.exprId)
          case e: Exists =>
            val tPlan = e.plan.transform {
              case lr: LogicalRelation
                if lr.relation.isInstanceOf[CarbonDatasourceHadoopRelation] =>
                lr.relation.asInstanceOf[CarbonDatasourceHadoopRelation].isSubquery += true
                lr
            }
            Exists(tPlan, e.children.map(_.canonicalized), e.exprId)

          case In(value, Seq(l:ListQuery)) =>
            val tPlan = l.plan.transform {
              case lr: LogicalRelation
                if lr.relation.isInstanceOf[CarbonDatasourceHadoopRelation] =>
                lr.relation.asInstanceOf[CarbonDatasourceHadoopRelation].isSubquery += true
                lr
            }
            In(value, Seq(ListQuery(tPlan, l.children, l.exprId)))
        }
    }
    transFormedPlan
  }
}

1	package org.apache.spark.sql.hive
2
3	import org.apache.spark.sql.CarbonDatasourceHadoopRelation
4	import org.apache.spark.sql.catalyst.expressions.{Exists, In, ListQuery, ScalarSubquery}
5	import org.apache.spark.sql.catalyst.plans.logical.{Filter, LogicalPlan}
6	import org.apache.spark.sql.execution.datasources.LogicalRelation
7
8	object CarbonOptimizerUtil {
9	def transformForScalarSubQuery(plan: LogicalPlan): LogicalPlan = {
10	// In case scalar subquery add flag in relation to skip the decoder plan in optimizer rule, And
11	// optimize whole plan at once.
12	val transFormedPlan = plan.transform {	1✔
13	case filter: Filter =>	1✔
14	filter.transformExpressions {	1✔
15	case s: ScalarSubquery =>	1✔
16	val tPlan = s.plan.transform {	1✔
17	case lr: LogicalRelation	1✔
18	if lr.relation.isInstanceOf[CarbonDatasourceHadoopRelation] =>	1✔
19	lr.relation.asInstanceOf[CarbonDatasourceHadoopRelation].isSubquery += true	1✔
20	lr	1✔
21	}
22	ScalarSubquery(tPlan, s.children, s.exprId)	1✔
23	case e: Exists =>	1✔
24	val tPlan = e.plan.transform {	1✔
25	case lr: LogicalRelation	1✔
26	if lr.relation.isInstanceOf[CarbonDatasourceHadoopRelation] =>	1✔
27	lr.relation.asInstanceOf[CarbonDatasourceHadoopRelation].isSubquery += true	1✔
28	lr	1✔
29	}
30	Exists(tPlan, e.children.map(_.canonicalized), e.exprId)	1✔
31
32	case In(value, Seq(l:ListQuery)) =>	1✔
33	val tPlan = l.plan.transform {	×
34	case lr: LogicalRelation	×
35	if lr.relation.isInstanceOf[CarbonDatasourceHadoopRelation] =>	×
36	lr.relation.asInstanceOf[CarbonDatasourceHadoopRelation].isSubquery += true	×
37	lr	×
38	}
39	In(value, Seq(ListQuery(tPlan, l.children, l.exprId)))	×
40	}
41	}
42	transFormedPlan	1✔
43	}
44	}	1✔

apache / carbondata / 10201

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous