scala — أسئلة مع إجابات

1 إجابة
أنا أتبع بعض دروس Spark التعليمية ، وعلى ما أزعجني ، يبدو أن المحاضر لا يتبع أفضل ممارسات Scala. يستخدم تغييرات var و state بينما أفضل العمل مع البيانات الثابتة. لذلك قمت بتغيير الشفرة الخاصة بي لتناسب النموذج الوظيفي بشكل أفضل ، ولكن بما أنني ما زلت جديدًا على اللغة ، فأنا لست 100٪ من الشفرة الخاص...
apache-spark
functional-programming
30.07.2018, 13:14
1 إجابة
لقد جربت الحلول الموضحة في كيفية تجاوز قيمة ضمنية؟ ، لكنه لا يساعد. هنا مثال رمز. تعريف تجريد TestImplicit مع تطبيقين مختلفين (تناظري ExecutionContextExecutor ): trait TestImplicit { def f(s:String):Unit } object TestImplicitImpl1 extends TestImplicit { override def f(s: String): Unit = printl...
implicit
overrides
30.07.2018, 12:07
1 إجابة
أريد الحصول على مجموع أ seq من Integer s في سكالا. في رأيي ، أود أن أضع علامة زائد على الأعداد الصحيحة مثل هذا: val seqOfIntegers:Seq[Int] = Seq(1, 2, 3, 4, 5) val sumOfIntegers = seqOfIntegers.reduce(+) هذا غير صالح. بدلاً من ذلك ، يجب أن أفعل: val sumOfIntegers = seqOfIntegers.reduce(plus) ......
reduce
infix-operator
30.07.2018, 11:42
1 إجابة
أنا أكتب اختبارات وحدة لتنفيذ نموذج ممثل akka. يحتوي النظام على فئات وسمات تحتاج إلى تهيئة. مشكلتي تكمن في اختبار الأساليب. عندما أسخر من المعلمات المطلوبة لفئة ما ، فإنه يزيل خطأ المترجم intelij ، ومع ذلك يتم تعيين جميع المتغيرات على قيمة خالية. لقد حاولت استخدام when(mock.answer).thenRe...
unit-testing
mockito
akka
actor
30.07.2018, 11:09
1 إجابة
أنا مشوشة قليلا. تقريبا كل تثبيت Hadoop "كيف" رأيت المحدد core-site.xml مجموعات fs.default.name إلى 9000 <configuration> <property> <name>fs.default.name</name> <value>hdfs://192.168.0.141:9000</value> </proper...
hadoop
14.07.2018, 22:56
1 إجابة
أنا أكتب مهمة coursera حيث تكمن المشكلة في حساب قيمة التعبير. لقد قدمت الرمز أدناه. في طريقة computeValues أحصل على NotInferredB1 كنوع بيانات متوقع. يمكن للشخص أن يشرح ما هو نوع البيانات NotInferred؟ هل يمكن أن تشرح أيضًا لماذا تتوقع NotInferred ، لأنني لا أفهم حيث تم تعريف القيم 1 على أنها (سلسل...
14.07.2018, 21:24
1 إجابة
أريد أن أكتب اختبار وحدة لفصل سكالا. الغرض من الفصل هو جمع المقاييس ونشرها على موضوع كافكا. أنا أحاول أن أسخر من المنتج في اختبار الوحدة لضمان سلامة بقية الكود. فيما يلي نسخة مبسطة من صفي: class MyEmitter(sparkConf: SparkConf) { <snip> -- member variables private val kafkaProducer = c...
unit-testing
mockito
mocking
scalatest
14.07.2018, 20:10
1 إجابة
لدي مشروعان منفصلان في إطار عمل 2.6.x ، كلاهما له مساراتهما الخاصة. كلاهما يريدان مشاركة نفس النماذج والإجراءات والرموز الأخرى التي لا تحتوي على تبعيات بشكل أساسي. كل شيء تحت نفس جذر VCS. ما هي أفضل طريقة لتنظيم هيكل المشروع بحيث يمكن أن يكون لدينا مشاريع Play حق الوصول إلى / اعتمادًا على النماذ...
playframework
devops
sbt
14.07.2018, 20:10
2 الاجابة
إعداد الكتلة - Driver has 28gb Workers have 56gb each (8 workers) ترتيب - spark.memory.offHeap.enabled true spark.driver.memory 20g spark.memory.offHeap.size 16gb spark.executor.memory 40g عملي - //myFunc just takes a string s and does some transformations on it, they are very small strings, but ...
apache-spark
19.06.2018, 19:10
2 الاجابة
أنا أكافح من أجل تسوية مجموعة البيانات الناتجة عن الانضمام إلى مجموعتي بيانات أخريين. أدناه هو رمز بلدي: val family = Seq( Person(0, "Agata", 0), Person(1, "Iweta", 0), Person(2, "Patryk", 2), Person(3, "Maksym", 0)).toDS val cities = Seq( City(0, "Warsaw"), ...
apache-spark
apache-spark-dataset
19.06.2018, 18:48
1 إجابة
انا استخدم sbt-native-packager . أضفت التعليمات البرمجية التالية إلى build.sbt enablePlugins(JavaAppPackaging) قمت بتشغيل هذا الأمر في قذيفة sbt sbt stage تم إنشاء مجلد عالمي. ويعمل مشروعي مع هذا الأمر في جهاز كمبيوتر يعمل بنظام Windows. لا توجد مشكلة. ./target/universal/stage/bin/ MyProjectNam...
akka
akka-http
sbt-native-packager
19.06.2018, 17:53
1 إجابة
لا بد لي من معالجة ملف OWL الخاص بي بلغة سكالا. لذلك وجدت هذا العبوس: https://github.com/phenoscape/scowl يسهل هذه المهمة. أنا أعمل مع Lunix و Virtual Machine. أسئلتي هي: كيفية تحميل scowl في Lunix مع سطر الأوامر؟ كيفية تحميل ملف البومة الخاص بي من github في Lunix؟ شكرا لك مقدما ...
ontology
owl-api
19.06.2018, 17:50
1 إجابة
هو سلوك الحصول على Iterator على مجموعة قابلة للتغيير (عبر .iterator ) ، تعديل المجموعة ثم التكرار مع المكرر الذي تم الحصول عليه مسبقًا جيد التحديد؟ على وجه الخصوص ل mutable.Map ؟؟؟ بشكل عام ، هل من الممكن تكرار وتعديل مجموعة قابلة للتغيير في نفس الوقت؟ أنا لا أتحدث عن موضوع متعدد هنا. لم أتمكن من...
scala-collections
19.06.2018, 17:21
1 إجابة
object MyObj extends Serializable{ private var a: String = _ private var b: String = _ //other vars handled in init ... def init(x: String, y: String): Unit = { this.a = x } def exec(z: String): String = { //want to return value x from init this.a ...
apache-spark
19.06.2018, 16:45
2 الاجابة
لدي شك بسيط حول Scala و subclass. لدي هذه الفئات: class A { def hello() = println("hello from A") } class B extends A { override def hello() = println("hello from B") } class C extends A { override def hello() = println("hello from C") } الآن ، في الصف الثالث هناك طريقة تسمى "hello (...
extends
subclass
19.06.2018, 16:32
فوق
قائمة طعام