apache / carbondata / 288

Build # 288

Build Type

push

jenkins

Committed by GitHub

Commit Message

<a href="https://github.com/apache/carbondata/commit/<a class=hub.com/apache/carbondata/commit/<a class="double-link" href="https://git"><a class=hub.com/apache/carbondata/commit/<a class="double-link" href="https://git"><a class=hub.com/apache/carbondata/commit/<a class="double-link" href="https://git"><a class=hub.com/apache/carbondata/commit/4e55e8696138895dcdd8f753d1a11e17bb4dbca6">4e55e8696">&lt;a href=&quot;https://github.com/apache/carbondata/commit/</a><a class="double-link" href="https://github.com/apache/carbondata/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/carbondata/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/carbondata/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/carbondata/commit/&lt;a class=&quot;double-link&quot; href=&quot;https://git">&lt;a class=</a>hub.com/apache/carbondata/commit/4e55e8696138895dcdd8f753d1a11e17bb4dbca6">4e55e8696</a><a href="https://github.com/apache/carbondata/commit/4e55e8696138895dcdd8f753d1a11e17bb4dbca6">&quot;&gt;&amp;lt;a href=&amp;quot;https://github.com/apache/carbondata/commit/&lt;/a&gt;&lt;a class=&quot;double-link&quot; href=&quot;https://github.com/apache/carbondata/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/carbondata/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/carbondata/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/carbondata/commit/&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://git&quot;&gt;&amp;lt;a class=&lt;/a&gt;hub.com/apache/carbondata/commit/4e55e8696138895dcdd8f753d1a11e17bb4dbca6&quot;&gt;4e55e8696&lt;/a&gt;&lt;a href=&quot;https://github.com/apache/carbondata/commit/4e55e8696138895dcdd8f753d1a11e17bb4dbca6&quot;&gt;&amp;quot;&amp;gt;&amp;amp;lt;a href=&amp;amp;quot;https://github.com/apache/carbondata/commit/&amp;lt;/a&amp;gt;&amp;lt;a class=&amp;quot;double-link&amp;quot; href=&amp;quot;https://github.com/apache/carbondata/commit/&amp;amp;lt;a ... (continued)

Run Details

185 of 185 new or added lines in 13 files covered. (100.0%)

65743 of 83711 relevant lines covered (78.54%)

1.04 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/util/Compaction.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.util

import org.apache.spark.sql.{CarbonEnv, SparkSession}
import org.apache.spark.sql.catalyst.TableIdentifier
import org.apache.spark.sql.execution.command.AlterTableModel
import org.apache.spark.sql.execution.command.management.CarbonAlterTableCompactionCommand
import org.apache.spark.sql.util.CarbonException

import org.apache.carbondata.core.constants.CarbonCommonConstants

/**
 * table compaction api
 */
 // scalastyle:off
object Compaction {

  def compaction(spark: SparkSession, dbName: String, tableName: String,
      compactionType: String): Unit = {
    TableAPIUtil.validateTableExists(spark, dbName, tableName)
    if (compactionType.equalsIgnoreCase(CarbonCommonConstants.MAJOR) ||
        compactionType.equalsIgnoreCase(CarbonCommonConstants.MINOR)) {
      CarbonAlterTableCompactionCommand(AlterTableModel(Some(dbName),
        tableName,
        None,
        compactionType,
        Some(System.currentTimeMillis()),
        "")).run(spark)
    }
    else {
      CarbonException.analysisException("Compaction type is wrong. Please select minor or major.")
    }

  }

  def main(args: Array[String]): Unit = {
    if (args.length < 3) {
      System.err.println("Usage: Compaction <store path> <table name> <major|minor>")
      System.exit(1)
    }

    val storePath = TableAPIUtil.escape(args(0))
    val (dbName, tableName) = TableAPIUtil.parseSchemaName(TableAPIUtil.escape(args(1)))
    val compactionType = TableAPIUtil.escape(args(2))
    val spark = TableAPIUtil.spark(storePath, s"Compaction: $dbName.$tableName")
    compaction(spark, dbName, tableName, compactionType)
  }
}

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	package org.apache.spark.util
18
19	import org.apache.spark.sql.{CarbonEnv, SparkSession}
20	import org.apache.spark.sql.catalyst.TableIdentifier
21	import org.apache.spark.sql.execution.command.AlterTableModel
22	import org.apache.spark.sql.execution.command.management.CarbonAlterTableCompactionCommand
23	import org.apache.spark.sql.util.CarbonException
24
25	import org.apache.carbondata.core.constants.CarbonCommonConstants
26
27	/**
28	* table compaction api
29	*/
30	// scalastyle:off
31	object Compaction {
32
33	def compaction(spark: SparkSession, dbName: String, tableName: String,
34	compactionType: String): Unit = {	×
35	TableAPIUtil.validateTableExists(spark, dbName, tableName)	×
36	if (compactionType.equalsIgnoreCase(CarbonCommonConstants.MAJOR) \|\|	×
37	compactionType.equalsIgnoreCase(CarbonCommonConstants.MINOR)) {	×
38	CarbonAlterTableCompactionCommand(AlterTableModel(Some(dbName),	×
39	tableName,	×
40	None,	×
41	compactionType,	×
42	Some(System.currentTimeMillis()),	×
43	"")).run(spark)	×
44	}
45	else {
46	CarbonException.analysisException("Compaction type is wrong. Please select minor or major.")	×
47	}
48
49	}
50
51	def main(args: Array[String]): Unit = {
52	if (args.length < 3) {	×
53	System.err.println("Usage: Compaction <store path> <table name> <major\|minor>")	×
54	System.exit(1)	×
55	}
56
57	val storePath = TableAPIUtil.escape(args(0))	×
58	val (dbName, tableName) = TableAPIUtil.parseSchemaName(TableAPIUtil.escape(args(1)))	×
59	val compactionType = TableAPIUtil.escape(args(2))	×
60	val spark = TableAPIUtil.spark(storePath, s"Compaction: $dbName.$tableName")	×
61	compaction(spark, dbName, tableName, compactionType)	×
62	}
63	}	×

apache / carbondata / 288

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