स्कैला एपीआई में एकाधिक कॉलम पर फ़िल्टर करने के लिए कोरेंट सिंटैक्स क्या है? मैं इस तरह कुछ करना चाहते हैं:स्पार्क एसक्यूएल फ़िल्टर एकाधिक फ़ील्ड्स
dataFrame.filter($"col01" === "something" && $"col02" === "something else")
या
dataFrame.filter($"col01" === "something" || $"col02" === "something else")
संपादित करें:
यह मेरा मूल कोड कैसा दिखता है। सब कुछ एक स्ट्रिंग के रूप में आता है।
df.select($"userID" as "user", $"itemID" as "item", $"quantity" cast("int"), $"price" cast("float"), $"discount" cast ("float"), sqlf.substring($"datetime", 0, 10) as "date", $"group")
.filter($"item" !== "" && $"group" !== "-1")
ठीक दिखता है। क्या आपको कोई समस्या है? – zero323
यदि यह काम नहीं करता है, तो हो सकता है कि आप 'sqlContext.implicits._' आयात करें', जहां 'sqlContext'' SQLContext' या 'HiveContext' का उदाहरण है। –
मुझे "मूल्य && स्ट्रिंग का सदस्य नहीं मिला"। समाधान प्रत्येक कथन को एक कोष्ठक में लपेटना है। – gstvolvr