Category "scala"

Scala Doobie. Creating and Inserting into a Temp Table

I am relatively new to Scala and also new to Doobie. I am connecting to SQL Server 2014 and need to create a temp table and subsequently insert into that temp

spark stateful streaming with checkpoint + kafka producer

How can I integrate Kafka producer with spark stateful streaming which uses checkpoint along with StreamingContext.getOrCreate. I read this post: How to write s

Extract value from array in Spark

I am trying to extract a value from an array in SparkSQL, but getting the error below: Example column customer_details {"original_customer_id":"ch_382820","fi

Why my Akka main actor stops even though behavior doesn't change?

I have written a small application, but there is a problem that my app doesn't wait for my actors to stop, and stops them before their actions are completed. I

Transpose a group of repeating columns in large horizontal dataframe into a new vertical dataframe using Scala or PySpark in databricks

This question although may seem previously answered it is not. All transposing seem to relate to one column and pivoting the data in that column. I want to ma

How to write Scala console output to a XML file?

I'm trying to convert json to xml, I am getting full output in console if the json file is small but I am trying to pass large json file n I'm not getting the

Dataframe in Scala

I am trying to train the model for recommendation for movie. I have a dataset which has list of all the casts, movie details with description. based on the occu

Dataframe in Scala

I am trying to train the model for recommendation for movie. I have a dataset which has list of all the casts, movie details with description. based on the occu

scala bubbleSort endless recursion

I am trying to get this implementation to work, tho it ends in an infinite loop. What am I missing? def bubbleSort(l: List[Int]): List[Int] = if(isSorted(l)) l

Update The Data in the Exisiting table based on different levels in Spark sql

I have this Existing table tb1 in my database Now new data comes and new data is stored in another table tb2 Earlier Account_Number 9988 was Level 2, But now

can we mock method inside object

object Abc { method1(param1,param2):Future[Option[String]] = { //some work } } We are using method1 somewhere and need to stub method1 how can

The identity monad as a free monad

The functor of the identity monad can be defined as: data Identity a = Identity a Because this monad is free, an alternative definition is the following: data

Visualizing dependency size via sbt assembly

I am using sbt assembly to package my project into one fat jar. I wanted to understand if I can visualize how much disk space is each dependency taking in my fa

In multi-stage compilation, should we use a standard serialisation method to ship objects through stages?

This question is formulated in Scala 3/Dotty but should be generalised to any language NOT in MetaML family. The Scala 3 macro tutorial: https://docs.scala-lang

scala add _2 s in a list of Tuple 2

I have the following mutable Hashmap in Scala: HashMap((b,3), (c,4), (a,8), (a,2)) and need to be converted to the following: HashMap((b,3), (c,4), (a,10)) I

command 'scala' not found after set up by coursier

I use coursier to set up the environment of Scala using command ./cs setup in Ubuntu 20.04 LTS. It was said that all the requirements were installed. However, w

Update a highly nested column from string to struct

Spark - Update a nested column to string

What causes AbstractMethodError for scala implicit val?

I have a gears library, depending on "org.typelevel" %% "cats-core" % "2.7.0", "org.typelevel" %% "cats-effect" % "2.5.4"

Can't figure out how to change Prometheus content type header

So my metrics all appear in one line at my end-point, not in new line per metric. I use micrometer, spring, prometheus and scala. My controller: @RequestMapping

Category "scala"

Other Categories