1920

Build # 1920

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/5b10cc5c4642373d408f9144713153cd539439ca">5b10cc5c4<a href="https://github.com/apache/carbondata/commit/5b10cc5c4642373d408f9144713153cd539439ca">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/82411f1f66d67c8e38be6ce1909ce87bf21123cd">82411f1f6</a>">82411f1f6</a><a href="https://github.com/apache/carbondata/commit/5b10cc5c4642373d408f9144713153cd539439ca"> into f599cb114">f599cb114</a>

Run Details

43 of 43 new or added lines in 9 files covered. (100.0%)

61647 of 77562 relevant lines covered (79.48%)

1.05 hits per line

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

76.19

/integration/spark2/src/main/spark2.2/org/apache/spark/sql/CarbonToSparkAdapater.scala

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *    http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */


package org.apache.spark.sql

import org.apache.spark.SparkContext
import org.apache.spark.scheduler.{SparkListener, SparkListenerApplicationEnd}
import org.apache.spark.sql.catalyst.expressions.{Alias, AttributeReference, AttributeSet, ExprId, Expression, ExpressionSet, NamedExpression}
import org.apache.spark.sql.catalyst.expressions.codegen.CodegenContext
import org.apache.spark.sql.catalyst.optimizer.OptimizeCodegen
import org.apache.spark.sql.catalyst.plans.logical.{LogicalPlan, OneRowRelation}
import org.apache.spark.sql.catalyst.rules.Rule
import org.apache.spark.sql.execution.command.ExplainCommand
import org.apache.spark.sql.internal.SQLConf
import org.apache.spark.sql.types.{DataType, Metadata}

object CarbonToSparkAdapater {

  def addSparkListener(sparkContext: SparkContext) = {
    sparkContext.addSparkListener(new SparkListener {
      override def onApplicationEnd(applicationEnd: SparkListenerApplicationEnd): Unit = {
        SparkSession.setDefaultSession(null)
        SparkSession.sqlListener.set(null)
      }
    })
  }

  def createAttributeReference(name: String, dataType: DataType, nullable: Boolean,
                               metadata: Metadata,exprId: ExprId, qualifier: Option[String],
                               attrRef : NamedExpression): AttributeReference = {
    AttributeReference(
      name,
      dataType,
      nullable,
      metadata)(exprId, qualifier,attrRef.isGenerated)
  }

  def createAliasRef(child: Expression,
                     name: String,
                     exprId: ExprId = NamedExpression.newExprId,
                     qualifier: Option[String] = None,
                     explicitMetadata: Option[Metadata] = None,
                     namedExpr: Option[NamedExpression] = None): Alias = {
    val isGenerated:Boolean = if (namedExpr.isDefined) {
      namedExpr.get.isGenerated
    } else {
      false
    }
    Alias(child, name)(exprId, qualifier, explicitMetadata,isGenerated)
  }

  def getExplainCommandObj() : ExplainCommand = {
    ExplainCommand(OneRowRelation)
  }

  def getPartitionKeyFilter(
      partitionSet: AttributeSet,
      filterPredicates: Seq[Expression]): ExpressionSet = {
    ExpressionSet(
      ExpressionSet(filterPredicates)
        .filter(_.references.subsetOf(partitionSet)))
  }

  def getOptimizeCodegenRule(conf :SQLConf): Seq[Rule[LogicalPlan]] = {
    Seq(OptimizeCodegen(conf))
  }
}

1	/*
2	* Licensed to the Apache Software Foundation (ASF) under one or more
3	* contributor license agreements. See the NOTICE file distributed with
4	* this work for additional information regarding copyright ownership.
5	* The ASF licenses this file to You under the Apache License, Version 2.0
6	* (the "License"); you may not use this file except in compliance with
7	* the License. You may obtain a copy of the License at
8	*
9	* http://www.apache.org/licenses/LICENSE-2.0
10	*
11	* Unless required by applicable law or agreed to in writing, software
12	* distributed under the License is distributed on an "AS IS" BASIS,
13	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14	* See the License for the specific language governing permissions and
15	* limitations under the License.
16	*/
17
18
19	package org.apache.spark.sql
20
21	import org.apache.spark.SparkContext
22	import org.apache.spark.scheduler.{SparkListener, SparkListenerApplicationEnd}
23	import org.apache.spark.sql.catalyst.expressions.{Alias, AttributeReference, AttributeSet, ExprId, Expression, ExpressionSet, NamedExpression}
24	import org.apache.spark.sql.catalyst.expressions.codegen.CodegenContext
25	import org.apache.spark.sql.catalyst.optimizer.OptimizeCodegen
26	import org.apache.spark.sql.catalyst.plans.logical.{LogicalPlan, OneRowRelation}
27	import org.apache.spark.sql.catalyst.rules.Rule
28	import org.apache.spark.sql.execution.command.ExplainCommand
29	import org.apache.spark.sql.internal.SQLConf
30	import org.apache.spark.sql.types.{DataType, Metadata}
31
32	object CarbonToSparkAdapater {
33
34	def addSparkListener(sparkContext: SparkContext) = {
35	sparkContext.addSparkListener(new SparkListener {	2✔
36	override def onApplicationEnd(applicationEnd: SparkListenerApplicationEnd): Unit = {
37	SparkSession.setDefaultSession(null)	×
38	SparkSession.sqlListener.set(null)	×
39	}
40	})
41	}
42
43	def createAttributeReference(name: String, dataType: DataType, nullable: Boolean,
44	metadata: Metadata,exprId: ExprId, qualifier: Option[String],
45	attrRef : NamedExpression): AttributeReference = {
46	AttributeReference(
47	name,	2✔
48	dataType,	2✔
49	nullable,	2✔
50	metadata)(exprId, qualifier,attrRef.isGenerated)	2✔
51	}
52
53	def createAliasRef(child: Expression,
54	name: String,
55	exprId: ExprId = NamedExpression.newExprId,	×
56	qualifier: Option[String] = None,	1✔
57	explicitMetadata: Option[Metadata] = None,	1✔
58	namedExpr: Option[NamedExpression] = None): Alias = {	1✔
59	val isGenerated:Boolean = if (namedExpr.isDefined) {	2✔
60	namedExpr.get.isGenerated	2✔
61	} else {
62	false	1✔
63	}
64	Alias(child, name)(exprId, qualifier, explicitMetadata,isGenerated)	2✔
65	}
66
67	def getExplainCommandObj() : ExplainCommand = {
68	ExplainCommand(OneRowRelation)	×
69	}
70
71	def getPartitionKeyFilter(
72	partitionSet: AttributeSet,
73	filterPredicates: Seq[Expression]): ExpressionSet = {
74	ExpressionSet(	2✔
75	ExpressionSet(filterPredicates)	2✔
76	.filter(_.references.subsetOf(partitionSet)))	2✔
77	}
78
79	def getOptimizeCodegenRule(conf :SQLConf): Seq[Rule[LogicalPlan]] = {
80	Seq(OptimizeCodegen(conf))	×
81	}
82	}	2✔

apache / carbondata / 1920

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