home
I wanted to convert this code written in Scala to Haskell. This code basically is an append only in...
Hi i need help please, how to optimize this code the all function use same condition in loop with...
I am trying to create Spark Scala code which can read any file with different number of columns....
I'm building a recommender system on Scala to run on AWS's EMR and Sagemaker. To train the model I...
I want to find a match (if any) for a regular expression on a string, but only testing after a...
I have an input string val x = "snapshot_year_month=201610,snapshot_day=05,source='zzz'" val y =...
Suppose I want to create a NonZero type so that my integer division function is total: def...
I'm processing data where some records may be corrupted. So I decided to explore the data and used...
Suppose I have a ADT in Scala: sealed trait Base case class Foo(i: Int) extends Base case class...
I have a beginner's question: I have a spark based scala project that uses junit. This is the...
The grpc-java library is a good example of a library that utilizes the common builder pattern for...
I'm currently working on migrating some python code to scala. I'm using breeze lib as a...
I am using assert function in scala in order to compare xml files. My problem is that I want to be...
Our application is running in a 3-node cluster. For distributing the work across the cluster, we...
I have a json {"status":"ok","totalResults":9,"articles":[{"source":{"id":"abc-news","name":"ABC...
Consider the following scenario with the following steps: Load a csv file into HDFS Read this...
I didn't find a way (documentation and API) to remove old snapshots with Akka Persistence Typed....
I have list of aggregation function, alias and other as JSON configuration, like { ...
10 hours ago

What is Type ev.R?

I have a ResultSet which is com.datastax.driver.core.ResultSet from which I am taking the...
Simply, I want to convert a multimap like this: val input = Map("rownum"-> List("1", "2", "3")...
I would like to cast scala collection types, such as Seq[Any] to Seq[(String, String)], without it...
I defined a class in models/ResponseQuery as follows: case class ResponseQuery( query: String, ...
My input is HBase table. first I am loading the data and function withCatalog will return...
I am working with a spark dataframe where it contains the entire timestamp values from the Column...
I have a file called query.txt in the folder src/main/resources of my project. Then I read this...
I want to declare few val fields and initialize them inside an init method so that I can use these...
I have a graph that reads lines from multiple gzipped files and writes those lines to another set...
The spark dataframe below has start_t and end_t in unix format but has an exponential e in it....
Have some employee data set. in that i need to partition based employee salary based on some...
This question already has an answer here: Why does foreach not bring...