मैं अपाचे स्पार्क के लिए नया हूं, और मैं इसे काम करने में सक्षम नहीं हूं। मेरे पास फॉर्म का आरडीडी है (इंट, (इंट, इंट)), और दूसरे तत्व को जोड़ते समय मूल्य के पहले तत्व को जोड़ना चाहते हैं। उदाहरण के लिए, मेरे पास निम्नलिखित आरडीडी है: [(5,(1,0)), (5,(1,2)), (5,(1,5)))] और मैं ऐसा कुछ प्राप्त करने म....
26 नवम्बर 2021, 05:05
मैं स्पार्क, स्कैला में नया हूं, बेवकूफ सवाल के लिए खेद है। तो मेरे पास कई टेबल हैं: टेबल_ए, टेबल_बी, ... और इन तालिकाओं के लिए संगत प्रकारों की संख्या केस क्लास क्लासए (...), केस क्लास क्लासबी (...), ... फिर मुझे एक ऐसी विधि लिखनी है जो इन तालिकाओं से डेटा पढ़ती है और डेटासेट बनाती है: def getData....
24 नवम्बर 2021, 00:17
उदाहरण के माध्यम से जाने पर http://aperiodic.net/phil/scala/s-99/p15. स्काला // P15 (**) Duplicate the elements of a list a given number of times. // Example: // scala> duplicateN(3, List('a, 'b, 'c, 'c, 'd)) // res0: List[Symbol] = List('a, 'a, 'a, 'b, 'b, 'b, 'c, 'c, 'c, 'c, 'c, 'c, ....
22 नवम्बर 2021, 11:28
यहाँ मेरा प्रश्न है: मेरे पास क्षेत्रों जैसे चाबियों वाला एक नक्शा है और इस क्षेत्र के व्यक्तियों की विशेषताओं का एक seq मान है: ("Asia" -> [Person(region: "Asia", hair: "brown", eyes: "blue",....), Person(.......) ("America" -> [Person(region: "America", hair: "red", eyes: "brown",....), Person(.......
21 नवम्बर 2021, 12:54
मैं स्कैला और अक्का स्ट्रीम के लिए थोडा नया हूं और मैं एक websocket से JSON स्ट्रिंग संदेश प्राप्त करने की कोशिश कर रहा हूं और उन्हें काफ्का विषय पर धक्का दे रहा हूं। अभी के लिए मैं केवल "डब्ल्यूएस से संदेश प्राप्त करें" भाग पर काम कर रहा हूं। वेबसोकेट से आने वाले संदेश इस तरह दिखते हैं: { "bit....
20 नवम्बर 2021, 17:01
मेरे पास कॉलम sig और N अन्य कॉलम के साथ निम्न डेटाफ़्रेम है। sig में N कॉलम की संख्या शामिल है, जैसा कि नीचे दिखाया गया है। एम्बेडेड कॉलम नाम डेटाफ़्रेम में मौजूद किसी भी संख्या के हो सकते हैं। मैं sig कॉलम को अन्य कॉलम से संबंधित मानों के साथ अपडेट करना चाहता हूं। उदाहरण के लिए, +-----------------....
20 नवम्बर 2021, 16:35
मुझे एक ऐसा फ़ंक्शन लिखना होगा जो JsValue प्राप्त करे, और उन चरणों को करें: जांचें कि क्या इसका प्रकार ऐरे है यदि यह ऐरे नहीं है, तो सूची के अंदर मान वापस करें यदि यह ऐरे है, तो जांचें कि क्या किसी ऑब्जेक्ट या साधारण टाइप (स्ट्रिंग, बूलियन इत्यादि) का ऐरे है। यदि इसका सरल प्रकार का ऐरे इस ऐरे को लौट....
17 नवम्बर 2021, 15:52
मेरे पास निम्न सरल कार्य है जहां मैं 0 के साथ सभी कॉलम लापता मानों को भर रहा हूं और फिर मानक विचलन की गणना कर रहा हूं। मुझे पता है कि मैं वर्णन फ़ंक्शन का उपयोग कर सकता हूं, लेकिन मैं इसे अपने उद्देश्य के लिए उपयोग करना चाहता था। def stdDevAllColumns(df: DataFrame): DataFrame = { df.select(df.col....
16 नवम्बर 2021, 08:08
मेरे पास स्कैला 3 प्रोजेक्ट (3.0.0 संस्करण) है और मैं http4s के साथ सरल रेस्ट एपीआई बनाने की कोशिश कर रहा हूं। मुझे JSON को डिकोडिंग/एन्कोडिंग में समस्या है। मैं http4s.g8 के आधार पर अपना कोड बना रहा हूं। समस्या यह पंक्ति: implicit val jokeDecoder: Decoder[Joke] = deriveDecoder[Joke] संकलन त्रुटि: ....
14 नवम्बर 2021, 10:24
मैं मशीन लर्निंग मॉडल को पहले से सहेजे गए स्पार्क में .sav फ़ाइल के रूप में लोड करना चाहता हूं जिसका मैंने उपयोग किया था val loaded_model = Pipeline.load("model_final.sav") या val loaded_model = PipelineModel.load("model_final.sav") मैं अपवाद को पूरा करता हूँ Exception in thread "main" java.la....
13 नवम्बर 2021, 23:52
तो मैं स्कैला के लिए नया हूं और जो मैंने ऑनलाइन पाया है, स्कैला अन्य भाषाओं की तरह वैरिएबल अपडेट नहीं करता है। मैं थोड़ी देर के लूप में एक चर बदलने की कोशिश कर रहा हूं लेकिन ऐसा लगता है कि यह बदल नहीं रहा है। मेरे पास एक परिवर्तनीय ऐरेबफर है जो कुंजी, मूल्य जोड़े धारण कर रहा है और इसे घोषित किया ग....
12 नवम्बर 2021, 21:02
अब तक मेरे पास टुपल्स की एक सरणी है जो कुंजी, मूल्य जोड़े से भरी हुई है (कुंजी इनट्स हैं और मान तार हैं)। val tuple_array = new Array[(K,V)](100) मैं इस सरणी में एक विशिष्ट कुंजी खोजना चाहता हूं। अब तक मैंने कोशिश की है: tuple_array.find() लेकिन इसके लिए मुझे एक कुंजी, मूल्य जोड़ी दर्ज करने की आव....
12 नवम्बर 2021, 18:52
मैं डेटाब्रिक्स पर चल रहा हूं। मैं एक xgboost मॉडल का उपयोग करने का प्रयास कर रहा हूं जिसे scala में xgboost4j-spark का उपयोग करके वितरित भविष्यवाणियों के लिए R में स्थानीय रूप से प्रशिक्षित किया गया था। डेटा Dataframe में है, जिसमें org.apache.spark.ml.linalg.Vectors.sparse के विरल वैक्टर के फीचर....
11 नवम्बर 2021, 23:36
मेरे पास निम्न case class हैं: case class Example[T]( obj: Option[T] | T = None, ) यह मुझे इसे Example(Some(myObject)) के बजाय Example(myObject) की तरह बनाने की अनुमति देता है। ओबीजे के साथ काम करने के लिए मुझे इसे Option[T] पर सामान्य करना होगा: lazy val maybeIn = obj match case o: Optio....
11 नवम्बर 2021, 11:33
मेरे पास एक एनोटेटेड ऑब्जेक्ट में कुछ गणनाएं हैं जैसे: @Schema(description = "Request description") case class Request( @Schema(description = "Enum1 description") field2: Enum1, @Schema(description = "Enum2 description") field2: Enum2 ) जहां enums के रूप में परिभाषित किया गया है: sea....
10 नवम्बर 2021, 15:18
कोर्सियर का उपयोग करके स्कैला 3.1.0 कैसे लॉन्च करें? मैंने कोशिश की और यह मिला ... ~ cs launch scala:3.1.0 Resolution error: Error downloading org.scala-lang:scala-compiler:3.1.0 not found: /Users/bh/.ivy2/local/org.scala-lang/scala-compiler/3.1.0/ivys/ivy.xml not found: https://repo1.maven.org/....
10 नवम्बर 2021, 08:33
दो मानचित्र दिए गए हैं val m1 = Map("a" -> "a") val m2 = Map("a" -> 1) उन दोनों को मिलाने के परिणामस्वरूप, मैं प्राप्त करना चाहूंगा Map("a" -> ("a",1)) मैंने इसके लिए बिल्लियों को सेमीग्रुपल करने की कोशिश की और इसने बहुत काम किया, लेकिन मुझे अपने आप से सेमीग्रुपल के लिए उदाहरण बनाना पड़ा, इस त....
10 नवम्बर 2021, 00:48
मैं एक ऐसी विधि को लागू करने की कोशिश कर रहा हूं जो इनपुट के रूप में ब्रीज़ वेक्टर या ब्रीज़ मैट्रिक्स को स्वीकार कर सके। कुछ इस तरह private def updateExponentialMovingAverage[T](tau: Double, initTheta: T, theta: T): T = { tau * theta + (1 - tau) * initTheta } हालांकि यह ओवरलोडिंग के साथ ए....
9 नवम्बर 2021, 19:27
मेरे पास यह कोड ठीक चल रहा है लेकिन फिर यह बहुत अधिक जानकारी दिखाता है और मुझे केवल कोड में अंतिम पंक्ति चाहिए। यहां कोड: import scala.io.Source object CovidWorld { def main(args: Array[String]): Unit = { val filename = Source.fromFile("OOPAssignment3.txt") try{ for (line <- fil....
9 नवम्बर 2021, 18:10
जब मैं sbt कंसोल my-app/run (my-app एक मॉड्यूल है) में अपना ऐप चलाता हूं, तो मुझे यह त्रुटि मिलती है java.io.FileNotFoundException: file:.../target/bg-jobs/sbt_eea980c4/job-3/target/aaa32a5e/b2227e4f/my-app_2.13-0.1.0-SNAPSHOT.jar!/my_file.csv मेरी निर्देशिका संरचना my-app->src->main->resources->my....
9 नवम्बर 2021, 05:54
पंडों में एक फ़ंक्शन है जो मेरे डेटाफ़्रेम के आकार की गणना करता है जो अंततः परिणाम की तरह है [total number of rows, total number of columns] मेरे पास निम्न फ़ंक्शन है जिसका उपयोग मैं अपने डेटाफ़्रेम का आकार प्राप्त करने के लिए PySpark में कर सकता हूं: print((df.count(), len(df.columns))) मैं स्कैल....
6 नवम्बर 2021, 04:38
लक्ष्य इस राशि को एक पुनरावर्ती कार्य में कोड करना है। सम मैंने अब तक इसे इस तरह कोड करने की कोशिश की है। def under(u: Int): Int = { var i1 = u/2 var i = i1+1 if ( u/2 == 1 ) then u + 1 - 2 * 1 else (u + 1 - 2 * i) + under(u-1) } ऐसा लगता है जैसे मैं रिकर्सिव भाग के साथ किसी समस....
5 नवम्बर 2021, 15:26
पोस्टग्रेज में मेरे पास दो टेबल हैं। पहले में फिल्मों के बारे में सामान्य जानकारी होती है, जबकि बाद में अभिनेता होते हैं। CREATE TABLE "MOVIES" ( "ID" uuid NOT NULL, "TITLE" character varying NOT NULL, "YEAR" smallint NOT NULL, "DIRECTOR" character varying NOT NULL ); CREATE TABLE "ACTORS"....
4 नवम्बर 2021, 23:49
मैं एक crossCompiled प्रोजेक्ट पर scalaVersion के मान के आधार पर, अपनी build.sbt स्क्रिप्ट पर निर्भरता और प्लगइन्स के लिए अलग-अलग संस्करण सेट करने का प्रयास कर रहा हूं। मेरे पास अब तक जो कुछ भी है उसका एक छोटा और सरलीकृत प्रतिनिधित्व यहां दिया गया है: scalaVersion := "2.11.12" crossScalaVersions := ....
4 नवम्बर 2021, 20:04
case class Fruit( apple: String, banana: String ) trait AppleComponent { self: HasDatabaseConfig[JdbcProfile] => import profile.api._ class Fruits(tag: Tag) extends Table[Fruit](tag, "fruits") { def apple = column[String]("....
4 नवम्बर 2021, 11:40