Skip to content

Commit c3ed7a5

Browse files
committed
left outer join 2 failing sporatically as well in multi case, is because
not every partition is getting a foreign row
1 parent a5af1ec commit c3ed7a5

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

src/enclave/Enclave/NonObliviousSortMergeJoin.cpp

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,9 @@
55
#include "FlatbuffersWriters.h"
66
#include "common.h"
77

8+
#include <iostream>
9+
using namespace std;
10+
811
/**
912
* C++ implementation of a non-oblivious sort merge join.
1013
* Rows MUST be tagged primary or secondary for this to work.

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

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -99,16 +99,14 @@ object OpaqueOperators extends Strategy {
9999
val sortOrder = sortForJoin(primaryKeysProj, tag, partitioned.output)
100100
val sorted = EncryptedSortExec(sortOrder, false, partitioned)
101101

102-
val addedNulls = EncryptedAddDummyRowsExec(1, sorted)
103-
104102
val joined = EncryptedSortMergeJoinExec(
105103
joinType,
106104
leftKeysProj,
107105
rightKeysProj,
108106
leftProjSchema.map(_.toAttribute),
109107
rightProjSchema.map(_.toAttribute),
110108
condition,
111-
addedNulls)
109+
sorted)
112110

113111
val tagsDropped = joinType match {
114112
case Inner | LeftOuter | RightOuter => EncryptedProjectExec(dropTags(left.output, right.output), joined)

0 commit comments

Comments
 (0)