Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[CARBONDATA-1251] Add test cases for IUD feature #1120

Closed
wants to merge 4 commits into from
Closed

[CARBONDATA-1251] Add test cases for IUD feature #1120

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
4 commits
Select commit Hold shift + click to select a range
36002d6
add test case when record more than one pagesize
chenerlu Jun 29, 2017
6be8a3b
delete unnecessary test case
chenerlu Jun 29, 2017
46f7a74
add test case for IUD feature
chenerlu Jun 30, 2017
4381ce8
add test case for IUD feature
chenerlu Jun 30, 2017
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
31 changes: 28 additions & 3 deletions .../src/test/scala/org/apache/carbondata/spark/testsuite/iud/DeleteCarbonTableTestCase.scala
View file
Open in desktop
Expand Up @@ -16,12 +16,10 @@
*/
package org.apache.carbondata.spark.testsuite.iud

import org.apache.spark.sql.Row
import org.apache.spark.sql.{Row, SaveMode}
import org.apache.spark.sql.common.util.QueryTest
import org.scalatest.BeforeAndAfterAll

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

class DeleteCarbonTableTestCase extends QueryTest with BeforeAndAfterAll {
override def beforeAll {
Expand Down Expand Up @@ -105,6 +103,33 @@ class DeleteCarbonTableTestCase extends QueryTest with BeforeAndAfterAll {
Seq(Row(3))
)
}

test("Records more than one pagesize after delete operation ") {
sql("DROP TABLE IF EXISTS default.carbon2")
import sqlContext.implicits._
val df = sqlContext.sparkContext.parallelize(1 to 2000000)
.map(x => (x+"a", "b", x))
.toDF("c1", "c2", "c3")
df.write
.format("carbondata")
.option("tableName", "carbon2")
.option("tempCSV", "true")
.option("compress", "true")
.mode(SaveMode.Overwrite)
.save()

checkAnswer(sql("select count(*) from default.carbon2"), Seq(Row(2000000)))

sql("delete from default.carbon2 where c1 = '99999a'").show()

checkAnswer(sql("select count(*) from default.carbon2"), Seq(Row(1999999)))

checkAnswer(sql("select * from default.carbon2 where c1 = '99999a'"), Seq())

sql("DROP TABLE IF EXISTS default.carbon2")
}


override def afterAll {
sql("use default")
sql("drop database if exists iud_db cascade")
Expand Down
2 changes: 2 additions & 0 deletions .../src/test/scala/org/apache/carbondata/spark/testsuite/iud/UpdateCarbonTableTestCase.scala
View file
Open in desktop
Expand Up @@ -406,6 +406,8 @@ class UpdateCarbonTableTestCase extends QueryTest with BeforeAndAfterAll {

checkAnswer(sql("select count(*) from default.carbon1"), Seq(Row(36000)))

checkAnswer(sql("select * from default.carbon1 where c1 = 'test123'"), Row("test123","b",9999))

sql("DROP TABLE IF EXISTS default.carbon1")
}

Expand Down