Skip to content

Commit 156adf9

Browse files
committed
added newly supported tpch queries
1 parent fc49497 commit 156adf9

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/main/scala/edu/berkeley/cs/rise/opaque/benchmark/TPCHBenchmark.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ object TPCHBenchmark {
4646
def run(sqlContext: SQLContext, numPartitions: Int, size: String, fileUrl: String) = {
4747
val tpch = new TPCH(sqlContext, size, fileUrl)
4848

49-
val supportedQueries = Seq(1, 3, 5, 6, 7, 8, 9, 10, 14, 17)
49+
val supportedQueries = Seq(1, 3, 5, 6, 7, 8, 9, 10, 12, 14, 17, 19, 20)
5050

5151
for (queryNumber <- supportedQueries) {
5252
query(queryNumber, tpch, sqlContext, numPartitions)

src/test/scala/edu/berkeley/cs/rise/opaque/TPCHTests.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@ import edu.berkeley.cs.rise.opaque.benchmark.TPCH
2626
trait TPCHTests extends OpaqueTestsBase { self =>
2727

2828
def size = "sf_small"
29-
def tpch = new TPCH(spark.sqlContext, size)
29+
def tpch = new TPCH(spark.sqlContext, size, "file://")
3030

3131
testAgainstSpark("TPC-H 1") { securityLevel =>
3232
tpch.query(1, securityLevel, numPartitions).collect

0 commit comments

Comments
 (0)