• เปรียบเทียบข้อมูลกับค่าที่รู้จัก
• ค้นหาข้อมูลในชุดที่กำหนดได้ง่าย
• ความเร็วเปรียบเทียบสูง

parsed_df = spark.read.parquet('parsed_data.parquet')
company_df = spark.read.parquet('companies.parquet')
verified_df = parsed_df.join(company_df, parsed_df.company == company_df.company)

การดำเนินการนี้จะลบแถวที่มีบริษัทไม่อยู่ใน valid_df ออกโดยอัตโนมัติ!