Skip to content

Commit a9120bb

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

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

src/main/scala/edu/berkeley/cs/rise/opaque/RA.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@ object RA extends Logging {
2929
def initRA(sc: SparkContext): Unit = {
3030

3131
// All executors need to be initialized before attestation can occur
32+
Thread.sleep(5000)
3233
var numExecutors = 1
3334
if (!sc.isLocal) {
3435
numExecutors = sc.getConf.getInt("spark.executor.instances", -1)

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)

0 commit comments

Comments
 (0)