शुरू करेंमुफ़्त में शुरू करें

DataFrames पर SQL के साथ Analytics

DataFrame ऑपरेशंस की तुलना में SQL क्वेरियाँ संक्षिप्त होती हैं और चलाना आसान होता है। लेकिन किसी DataFrame पर SQL क्वेरियाँ लगाने के लिए, पहले आपको उस DataFrame की एक अस्थायी view को टेबल के रूप में बनाना होता है, और फिर उसी बनी हुई टेबल पर SQL क्वेरियाँ चलानी होती हैं.

आपके वर्कस्पेस में पहले से ही SparkContext spark और salaries_df उपलब्ध हैं।

यह अभ्यास पाठ्यक्रम का हिस्सा है

PySpark परिचय

पाठ्यक्रम देखें

अभ्यास निर्देश

  • salaries_df DataFrame से अस्थायी टेबल "salaries_table" बनाएँ।
  • कनाडा ("CA") में company_location से "job_title" कॉलम निकालने के लिए एक क्वेरी बनाएँ।
  • SQL क्वेरी चलाकर नया DataFrame canada_titles बनाएँ।
  • टेबल का सार-संक्षेप प्राप्त करें।

इंटरैक्टिव व्यावहारिक अभ्यास

इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।

# Create a temporary view of salaries_table
salaries_df.____('salaries_table')

# Construct the "query"
query = '''SELECT job_title, salary_in_usd FROM ____ WHERE company_location == "CA"'''

# Apply the SQL "query"
canada_titles = spark.____(____)

# Generate basic statistics
canada_titles.____().show()
कोड संपादित करें और चलाएँ