Colocated part and partsupp tables in tpch.

TIBCOSoftware · Jul 19, 2016 · 0daea47 · 0daea47
1 parent 7d32d5a
commit 0daea47
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/cluster/src/test/scala/io/snappydata/benchmark/TPCHColumnPartitionedTable.scala b/cluster/src/test/scala/io/snappydata/benchmark/TPCHColumnPartitionedTable.scala
@@ -373,7 +373,7 @@ object TPCHColumnPartitionedTable  {
     val partSuppDF = sqlContext.createDataFrame(partSuppReadings)
 
     if (isSnappy) {
-      val p1 = Map(("PARTITION_BY"-> "ps_partkey"),("BUCKETS"->buckets))
+      val p1 = Map(("PARTITION_BY"-> "ps_partkey"),("BUCKETS"->buckets),("COLOCATE_WITH"->"PART"))
 
       val snappyContext = sqlContext.asInstanceOf[SnappyContext]
       snappyContext.dropTable("PARTSUPP", ifExists = true)

diff --git a/cluster/src/test/scala/io/snappydata/benchmark/snappy/TPCH_Snappy.scala b/cluster/src/test/scala/io/snappydata/benchmark/snappy/TPCH_Snappy.scala
@@ -1148,8 +1148,8 @@ object TPCH_Snappy {
            "         from" +
            "                 PART," +
            "                 LINEITEM_PART," +
-           "                 SUPPLIER," +
            "                 PARTSUPP," +
+           "                 SUPPLIER," +
            "                 ORDERS," +
            "                 NATION" +
            "         where" +