We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent b2b20b0 commit 2eebc3fCopy full SHA for 2eebc3f
src/main/scala/app/task4/Task4Workshop.scala
@@ -15,6 +15,6 @@ object Task4Workshop extends App with SparkWrapper {
15
16
spark.stop()
17
18
- def enrich(data: DataFrame, additionalInfo: DataFrame): DataFrame =
19
- data.join(additionalInfo, "CustomerId")
+ def enrich(data: DataFrame, additionalInfo: DataFrame): DataFrame = null
+ // join data with additionalInfo on CustomerId, hint: data.join
20
}
src/test/scala/app/task4/Task4WorkshopTest.scala
@@ -1,8 +1,10 @@
1
package app.task4
2
3
import app.SparkSessionTestWrapper
4
+import org.scalatest.Ignore
5
import org.scalatest.matchers.should.Matchers.convertToAnyShouldWrapper
6
7
+@Ignore
8
class Task4WorkshopTest extends org.scalatest.FunSuite with SparkSessionTestWrapper {
9
10
test("testEnrich") {
0 commit comments