Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2652#discussion_r213946805
--- Diff:
integration/spark-common-test/src/test/scala/org/apache/carbondata/spark/testsuite/createTable/TestNonTransactionalCarbonTable.scala
---
@@ -2364,6 +2364,83 @@ class TestNonTransactionalCarbonTable extends
QueryTest with BeforeAndAfterAll {
checkAnswer(sql("select * from sdkOutputTable"),
Seq(Row(Timestamp.valueOf("1970-01-02 16:00:00"),
Row(Timestamp.valueOf("1970-01-02 16:00:00")))))
}
+ test("test Sort Scope with Local_Sort for SDK") {
+
+ cleanTestData()
+ var options = Map("sort_scope" -> "local_sort").asJava
+
+ val fields: Array[Field] = new Array[Field](4)
+ fields(0) = new Field("stringField", DataTypes.STRING)
+ fields(1) = new Field("intField", DataTypes.INT)
+
+ val builder: CarbonWriterBuilder = CarbonWriter.builder
+
.outputPath(writerPath).isTransactionalTable(false).withLoadOptions(options)
--- End diff --
write in multiple lines
---
