Question 17
You are provided with a Spark program that picks out a list of suspicious transactions based on the amount of the transaction being higher than a threshold and the geographic location of the transaction matching a known set of suspected locations provided in a small file. The Spark program is written to pull all the transactions from the Workers to the Driver and then apply the logic of threshold filtering and geographic location matching. Which of the following changes will you make to the program to improve performance? (Choose any two)
Use broadcast variables
Hardcode threshold value as a filter condition in the Driver program
Filter for transactions in the Workers before bringing to the Driver
Hardcode threshold value as a filter condition in the Workers itself