2016-08-19 4 views
6

मैं निम्न पंक्ति को क्रियान्वित करते हुए प्रकार pyspark.sql.dataframe.DataFrame के dataframe बनाई में एक एसक्यूएल मेज पर वापस एक pyspark.sql.dataframe.DataFrame परिवर्तित कर सकते हैं: dataframe = sqlContext.sql("select * from my_data_table")मैं कैसे databricks नोटबुक

मैं एक को यह वापस कैसे परिवर्तित कर सकते हैं sparksql तालिका है कि मैं एसक्यूएल प्रश्नों को चला सकते हैं?

उत्तर

4

आप createReplaceTempView का उपयोग करके अपनी तालिका बना सकते हैं।

dataframe.createOrReplaceTempView("mytable") 

इस के बाद आप अपने mytableएसक्यूएल का उपयोग कर क्वेरी कर सकते हैं: आपके मामले में ऐसा नहीं होगा।

अपने एक चिंगारी संस्करण 1.6.2 ≤ है जब मैं `dataframe.createOrReplaceTempView (" mytable ") चलाने आप registerTempTable

+1

उपयोग कर सकते हैं' मैं निम्नलिखित त्रुटि मिलती है: 'DataFrame' ऑब्जेक्ट कोई विशेषता 'है createOrReplaceTempView ' – Semihcan

+0

अपाचे स्पार्क का कौन सा संस्करण आप उपयोग कर रहे हैं? –

+0

मैं 1.5.2 का उपयोग कर रहा हूं – Semihcan

संबंधित मुद्दे