1256

Build # 1256

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/e89b224b48d620c9f1500823172d5943f12981b3">e89b224b4<a href="https://github.com/apache/carbondata/commit/e89b224b48d620c9f1500823172d5943f12981b3">">Merge </a><a class="double-link" href="https://github.com/apache/carbondata/commit/<a class="double-link" href="https://github.com/apache/carbondata/commit/e33d4ea1091c731ca822131c826a10114994e01e">e33d4ea10</a>">e33d4ea10</a><a href="https://github.com/apache/carbondata/commit/e89b224b48d620c9f1500823172d5943f12981b3"> into 3d3b6ff16">3d3b6ff16</a>

Run Details

34 of 34 new or added lines in 10 files covered. (100.0%)

60608 of 76342 relevant lines covered (79.39%)

1.05 hits per line

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

0.0

/integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CarbonShowSummaryCommand.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.execution.command.management

import java.util

import scala.collection.JavaConverters._

import org.apache.spark.sql.{CarbonEnv, Row, SparkSession}
import org.apache.spark.sql.catalyst.expressions.{Attribute, AttributeReference}
import org.apache.spark.sql.execution.command.{Checker, DataCommand}
import org.apache.spark.sql.types.StringType

import org.apache.carbondata.tool.CarbonCli

/**
 * Show summary command class which is integrated to cli and sql support is provided via this class
 * @param databaseNameOp
 * @param tableName
 * @param commandOptions
 */
case class CarbonShowSummaryCommand(
    databaseNameOp: Option[String],
    tableName: String,
    commandOptions: Map[String, String])
  extends DataCommand {

  override def output: Seq[Attribute] = {
      Seq(AttributeReference("Table Summary", StringType, nullable = false)())
  }

  override def processData(sparkSession: SparkSession): Seq[Row] = {
    Checker.validateTableExists(databaseNameOp, tableName, sparkSession)
    val carbonTable = CarbonEnv.getCarbonTable(databaseNameOp, tableName)(sparkSession)
    val commandArgs: Seq[String] = commandOptions("command").split(",")
    val finalCommands = commandArgs.collect {
      case a if a.trim.equalsIgnoreCase("-p") =>
        Seq(a, carbonTable.getTablePath)
      case x => Seq(x.trim)
    }.flatten
    val summaryOutput = new util.ArrayList[String]()
    CarbonCli.run(finalCommands.toArray, summaryOutput)
    summaryOutput.asScala.map(x =>
      Row(x)
    )
  }
}

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	package org.apache.spark.sql.execution.command.management
19
20	import java.util
21
22	import scala.collection.JavaConverters._
23
24	import org.apache.spark.sql.{CarbonEnv, Row, SparkSession}
25	import org.apache.spark.sql.catalyst.expressions.{Attribute, AttributeReference}
26	import org.apache.spark.sql.execution.command.{Checker, DataCommand}
27	import org.apache.spark.sql.types.StringType
28
29	import org.apache.carbondata.tool.CarbonCli
30
31	/**
32	* Show summary command class which is integrated to cli and sql support is provided via this class
33	* @param databaseNameOp
34	* @param tableName
35	* @param commandOptions
36	*/
37	case class CarbonShowSummaryCommand(	×
38	databaseNameOp: Option[String],	×
39	tableName: String,	×
40	commandOptions: Map[String, String])	×
41	extends DataCommand {	×
42
43	override def output: Seq[Attribute] = {
44	Seq(AttributeReference("Table Summary", StringType, nullable = false)())	×
45	}
46
47	override def processData(sparkSession: SparkSession): Seq[Row] = {
48	Checker.validateTableExists(databaseNameOp, tableName, sparkSession)	×
49	val carbonTable = CarbonEnv.getCarbonTable(databaseNameOp, tableName)(sparkSession)	×
50	val commandArgs: Seq[String] = commandOptions("command").split(",")	×
51	val finalCommands = commandArgs.collect {	×
52	case a if a.trim.equalsIgnoreCase("-p") =>	×
53	Seq(a, carbonTable.getTablePath)	×
54	case x => Seq(x.trim)	×
55	}.flatten	×
56	val summaryOutput = new util.ArrayList[String]()	×
57	CarbonCli.run(finalCommands.toArray, summaryOutput)	×
58	summaryOutput.asScala.map(x =>	×
59	Row(x)	×
60	)
61	}
62	}

apache / carbondata / 1256

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