ถามตอบปัญหาและข้อมูลเกี่ยวกับ scala

การทดสอบหน่วยคาฟคา

ฉันมีฟังก์ชัน KafkaIngestion ซึ่งสร้าง DF จาก kafkatopic ด้วยวิธีต่อไปนี้ def kafkaIngestion(spark:sparksession):Dataframe={ val df=spark.read.format("kafka") ตัวเลือก ("...

• scala • unit-testing • apache-kafka • mockito

เหตุใดสกาล่าจึงไม่มีแอปพลิเคชันบางส่วนตามปกติ

ฉันสงสัยว่าเหตุใด Scala จึงไม่สามารถใช้รูปแบบแอพพลิเคชั่นบางส่วนสำหรับฟังก์ชั่นเหมือนกับภาษาโปรแกรมอื่น ๆ ที่ใช้งานได้ ประโยชน์ของรายการพารามิเตอร์หลายรายการคืออะไร มันมีอะไรทำ...

เหตุใดฉันจึงได้รับการเข้าร่วมแบบข้ามโดยปริยายภายในวิธีการ แต่ไม่ใช่ภายนอก

ฉันถูกขอให้แก้ไขจุดบกพร่องในการผลิต ฉันได้ปรับโครงสร้างโค้ดใหม่แล้ว แต่ยังได้รับข้อผิดพลาดการเข้าร่วมไขว้ที่อนุมานได้ วิธีการมีดังนี้ คลาส FinancialProfitTransform (จุดประกาย: SparkSession, config: ...

ฟังก์ชัน Mockito-Mock ภายในอ็อบเจ็กต์ scala สำหรับการทดสอบหน่วย

ฉันมีฟังก์ชันบางอย่างภายในอ็อบเจกต์สกาล่า ฟังก์ชันภายในเรียกฟังก์ชันอื่นๆ ของออบเจ็กต์เดียวกัน วัตถุ A { def method1:Unit= { Method2() } def Method2:Int= { ...

ไม่สามารถแก้ไขการนำเข้า sqlContext แม้ว่าจะกำหนดด้วยอินสแตนซ์ของ SQLContext

ฉันทำตามวิธีแก้ปัญหาที่นี่ แต่ฉันยังคงได้รับข้อผิดพลาด "ไม่สามารถแก้ไขสัญลักษณ์ SQLContext" ".implicits._" ไม่สามารถแก้ไขได้เช่นกัน จะเป็นเพราะอะไร...

วิธีการแทนที่การผูกใน submodules ลูกย่อยในการเล่น scala

ฉันมีแอปพลิเคชั่นหลายโมดูล scala play ที่มี 3 โมดูล: ทั่วไป, โมดูล A และโมดูล B โดยที่โมดูล A และโมดูล B ขึ้นอยู่กับทั่วไป ModuleA และ moduleB ควรผูกมัดการใช้งานที่แตกต่างกันสำหรับลักษณะ ...

เพิ่มฟังก์ชันการส่งอีเมลในรหัส Scala ของฉันใน databricks

ฉันต้องการเพิ่มส่วนการแจ้งเตือนทางอีเมลในรหัสสกาล่าของฉันใน databricks ฉันกำลังพยายามนำเข้า --- นำเข้า org.apache.commons.mail._ แต่ได้รับข้อผิดพลาดด้านล่าง: object mail ไม่ใช่สมาชิกของ package org....

scalariform: เพิ่มข้อยกเว้นให้กับ NonASCIICharacterChecker

เรามีฟีเจอร์สเกลาริฟอร์มที่เปิดใช้งานในโครงการของเราดังนี้: <check level="error" class="org.scalastyle.scalariform.NonASCIICharacterChecker" enable="true"/&&...

Action หมายถึงอะไรในกรอบการเล่น (Scala)?

ฉันยังใหม่กับ Play Framework และพยายามทำความเข้าใจคลาส SimpleRouter ในเอกสารประกอบ Play ฉันดูตัวอย่างง่ายๆ เช่น: val router = Router.from { case GET(p"/hello/$to") => ...

ไม่มีประเภทพารามิเตอร์สำหรับฟังก์ชันขยาย (Scala)

นี่คือฟังก์ชันของฉัน: def sumOfSquaresOfOdd(in: Seq[Int]): Int = { in.filter(_%2==1).map(_*_).reduce(_+_) } เหตุใดฉันจึงได้รับข้อผิดพลาด "ไม่มีประเภทพารามิเตอร์สำหรับฟังก์ชันขยาย"?

dropDuplicates ด้วยเงื่อนไขที่ไม่ใช่ตัวเลข

ฉันมี dataframe ที่มีลักษณะดังนี้ (ฉันมีอีกสองสามคอลัมน์ แต่ไม่เกี่ยวข้อง): +-----------+-----------+- --------------+ |item_id |...

ข้อยกเว้นสกาล่าในเธรด "main" java.lang.NoSuchMethodError

ฉันยังใหม่กับการเขียนโปรแกรม Scala และกำลังใช้ IntelliJ IDE ฉันได้รับข้อยกเว้นด้านล่างเมื่อฉันเรียกใช้โค้ดตัวอย่าง Scala ไม่แน่ใจว่าฉันขาดการพึ่งพาหรือไม่ ตัวอย่างโค้ดแพ็กเกจ com.assessments....

Scala-Redis: จะเชื่อมต่อแคช redis ทั่วโลกใน Scala ได้อย่างไร

ฉันใช้ scala-redis เพื่อเชื่อมต่อกับฐานข้อมูล redis ทั่วโลก ฉันสามารถเชื่อมต่อได้อย่างง่ายดายกับเซิร์ฟเวอร์ redis ที่ทำงานอยู่ในเครื่อง แต่ไม่แน่ใจว่าจะส่งผ่านอะไรในตัวสร้างเพื่อเชื่อมต่อกับ ...

เหตุใด foldRight จึงไม่นับจำนวนที่ถูกต้อง

ฉันกำลังพยายามคำนวณจำนวนองค์ประกอบในรายการโดยใช้วิธี foldRight และ foldLeft ในขณะที่ foldLeft ให้การนับ foldRight ที่ถูกต้องแก่ฉัน รหัสฉันผิดตรงไหน def นับ (arr:...

จะประกาศหลายขอบเขตให้กับประเภทของตัวแปรได้อย่างไร?

ใน Scala ฉันสามารถเขียน: val x: Serializable with Runnable = ??? ฉันจะทำเช่นเดียวกันใน Kotlin และ Java ได้อย่างไร