employee = sc.parallelize(employee).map(lambda e: (e[1], e[0]))
department = sc.parallelize(department).map(lambda d: (d, 0))
employee.join(department).map(lambda e: (e[1][0], e[0])).collect()
Filter based on another RDD in Spark