ฉันมีฟังก์ชัน KafkaIngestion ซึ่งสร้าง DF จาก kafkatopic ด้วยวิธีต่อไปนี้ def kafkaIngestion(spark:sparksession):Dataframe={ val df=spark.read.format("kafka") ตัวเลือก ("...
• scala • unit-testing • apache-kafka • mockitoฉันสงสัยว่าเหตุใด Scala จึงไม่สามารถใช้รูปแบบแอพพลิเคชั่นบางส่วนสำหรับฟังก์ชั่นเหมือนกับภาษาโปรแกรมอื่น ๆ ที่ใช้งานได้ ประโยชน์ของรายการพารามิเตอร์หลายรายการคืออะไร มันมีอะไรทำ...
ฉันถูกขอให้แก้ไขจุดบกพร่องในการผลิต ฉันได้ปรับโครงสร้างโค้ดใหม่แล้ว แต่ยังได้รับข้อผิดพลาดการเข้าร่วมไขว้ที่อนุมานได้ วิธีการมีดังนี้ คลาส FinancialProfitTransform (จุดประกาย: SparkSession, config: ...
ฉันมีฟังก์ชันบางอย่างภายในอ็อบเจกต์สกาล่า ฟังก์ชันภายในเรียกฟังก์ชันอื่นๆ ของออบเจ็กต์เดียวกัน วัตถุ A { def method1:Unit= { Method2() } def Method2:Int= { ...
ฉันทำตามวิธีแก้ปัญหาที่นี่ แต่ฉันยังคงได้รับข้อผิดพลาด "ไม่สามารถแก้ไขสัญลักษณ์ SQLContext" ".implicits._" ไม่สามารถแก้ไขได้เช่นกัน จะเป็นเพราะอะไร...
ฉันมีแอปพลิเคชั่นหลายโมดูล scala play ที่มี 3 โมดูล: ทั่วไป, โมดูล A และโมดูล B โดยที่โมดูล A และโมดูล B ขึ้นอยู่กับทั่วไป ModuleA และ moduleB ควรผูกมัดการใช้งานที่แตกต่างกันสำหรับลักษณะ ...
ฉันต้องการเพิ่มส่วนการแจ้งเตือนทางอีเมลในรหัสสกาล่าของฉันใน databricks ฉันกำลังพยายามนำเข้า --- นำเข้า org.apache.commons.mail._ แต่ได้รับข้อผิดพลาดด้านล่าง: object mail ไม่ใช่สมาชิกของ package org....
เรามีฟีเจอร์สเกลาริฟอร์มที่เปิดใช้งานในโครงการของเราดังนี้: <check level="error" class="org.scalastyle.scalariform.NonASCIICharacterChecker" enable="true"/&&...
ฉันยังใหม่กับ Play Framework และพยายามทำความเข้าใจคลาส SimpleRouter ในเอกสารประกอบ Play ฉันดูตัวอย่างง่ายๆ เช่น: val router = Router.from { case GET(p"/hello/$to") => ...
นี่คือฟังก์ชันของฉัน: def sumOfSquaresOfOdd(in: Seq[Int]): Int = { in.filter(_%2==1).map(_*_).reduce(_+_) } เหตุใดฉันจึงได้รับข้อผิดพลาด "ไม่มีประเภทพารามิเตอร์สำหรับฟังก์ชันขยาย"?
ฉันมี dataframe ที่มีลักษณะดังนี้ (ฉันมีอีกสองสามคอลัมน์ แต่ไม่เกี่ยวข้อง): +-----------+-----------+- --------------+ |item_id |...
ฉันยังใหม่กับการเขียนโปรแกรม Scala และกำลังใช้ IntelliJ IDE ฉันได้รับข้อยกเว้นด้านล่างเมื่อฉันเรียกใช้โค้ดตัวอย่าง Scala ไม่แน่ใจว่าฉันขาดการพึ่งพาหรือไม่ ตัวอย่างโค้ดแพ็กเกจ com.assessments....
ฉันใช้ scala-redis เพื่อเชื่อมต่อกับฐานข้อมูล redis ทั่วโลก ฉันสามารถเชื่อมต่อได้อย่างง่ายดายกับเซิร์ฟเวอร์ redis ที่ทำงานอยู่ในเครื่อง แต่ไม่แน่ใจว่าจะส่งผ่านอะไรในตัวสร้างเพื่อเชื่อมต่อกับ ...
ฉันกำลังพยายามคำนวณจำนวนองค์ประกอบในรายการโดยใช้วิธี foldRight และ foldLeft ในขณะที่ foldLeft ให้การนับ foldRight ที่ถูกต้องแก่ฉัน รหัสฉันผิดตรงไหน def นับ (arr:...
ใน Scala ฉันสามารถเขียน: val x: Serializable with Runnable = ??? ฉันจะทำเช่นเดียวกันใน Kotlin และ Java ได้อย่างไร