Indhumathi27 commented on a change in pull request #4050:
URL:
https://github.com/apache/carbondata/pull/4050#discussion_r540006038##########
File path: integration/spark/src/test/scala/org/apache/carbondata/spark/testsuite/segmentreading/TestSegmentReading.scala
##########
@@ -420,4 +421,69 @@ class TestSegmentReading extends QueryTest with BeforeAndAfterAll {
sql("set spark.sql.adaptive.enabled=false")
}
+
+ test("Read marked for delete segments") {
+ sql("drop table if exists carbonTable")
+ sql(
+ "create table carbonTable(a string, b int, c string) stored as carbondata ")
+ sql("insert into carbonTable values ('k',1,'k'), ('k',1,'b')")
+ sql("insert into carbonTable values ('a',2,'a')")
+ sql("insert into carbonTable values ('b',2,'b'),('b',2,'b')")
+ sql("insert into carbonTable values ('c',2,'c')")
+
+ sql("delete from table carbonTable where segment.id in (0,3)")
+ sql("set carbon.input.segments.default.carbonTable = 0,2,3")
+
+ checkAnswer(sql("select count(*) from carbonTable"), Seq(Row(2)))
+ }
+
+ test("Read marked for delete segments after SI creation") {
+ sql("drop table if exists carbonTable")
+ sql(
+ "create table carbonTable(a string, b int, c string) stored as carbondata ")
+ sql("insert into carbonTable values ('k',1,'k'), ('k',1,'b')")
+ sql("insert into carbonTable values ('a',2,'a')")
+ sql("insert into carbonTable values ('b',2,'b'),('b',2,'b')")
+ sql("insert into carbonTable values ('c',2,'c')")
+
+ sql("drop index if exists indextable1 on carbonTable")
+ sql("create index indextable1 on table carbonTable (c) AS 'carbondata'")
+
+ sql("delete from table carbonTable where segment.id in (0,3)")
+ sql("set carbon.input.segments.default.carbonTable = 0,2,3")
+
+ checkAnswer(sql("select count(*) from carbonTable"), Seq(Row(2)))
+ }
+
+ test("Read compacted segments") {
+ sql("drop table if exists carbonTable")
+ sql(
+ "create table carbonTable(a string, b int, c string) stored as carbondata")
+ sql("insert into carbonTable values ('k',5,'k'), ('k',5,'b')")
+ sql("insert into carbonTable values ('a',1,'a')")
+ sql("insert into carbonTable values ('b',2,'b'),('b',2,'b')")
+ sql("insert into carbonTable values ('c',3,'c')")
+ sql("alter table carbonTable compact 'major'")
+
+ sql("set carbon.input.segments.default.carbonTable = 0,1,2,3,0.1")
+ checkAnswer(sql("select count(*) from carbonTable"), Seq(Row(6)))
+ }
+
+ test("Read compacted segments after SI creation") {
+ sql("drop table if exists carbonTable")
+ sql(
+ "create table carbonTable(a string, b int, c string) stored as carbondata")
+ sql("insert into carbonTable values ('k',5,'k'), ('k',5,'b')")
+ sql("insert into carbonTable values ('a',1,'a')")
+ sql("insert into carbonTable values ('b',2,'b'),('b',2,'b')")
+ sql("insert into carbonTable values ('c',3,'c')")
+
+ sql("drop index if exists indextable1 on carbonTable")
+ sql("create index indextable1 on table carbonTable (c) AS 'carbondata'")
+
+ sql("alter table carbonTable compact 'major'")
+ sql("set carbon.input.segments.default.carbonTable = 0,1,2,3,0.1")
+ checkAnswer(sql("select count(*) from carbonTable"), Seq(Row(6)))
Review comment:
add a query check which has filter on SI column
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[hidden email]
Locked
