I am trying to compare two columns in a dataframe and to find out the rate of change of value.
I wrote a UDF to achieve this but getting error while executing.
Below is the data structure in the ...
I am new to scala and need to make a small change in the form tag. Currently the form tag in my html page is written like
I need to add onsubmit ...
I am upgrading to latest version of phantom-dsl 2.42.0 and scala 2.12 and according to migration guide now I do not require to generate fromRow() method but while querying the database I am getting no ...
I have a file with some records.
I have written below code, it is working for the one word but when I give the seq variable term I am not getting the output, can anyone tell me how to solve this.
val term = List("Achieving","Making")...
I'm new to Scala and trying to create UDF function which would return string of concatenated tuples identified by my UDF function. It should look something like this, but have couple of problems here, ...
I am complete beginner trying to run one program connected with game called Path of exile.
I instalsed java sbt and ran test i have in console sbt:system32>. But my project is loaded from system32/...
I am working on a Gatling test framework that can be parameterized through external config objects. One use case I have is that there may be zero or more CSS selector checks that need to be saved to ...
I have two table ->
table1: RDD[Rating] (rdd1,rdd2,rdd3)
table2: scala.collection.Map[Int, Double] (m1,m2)
I spent a lot of time and effort trying to make joined table like
I have an input list of strings, which I'd like to translate to list of objects using regex. In the code below, I am not creating the objects but printing them to stdout for simplicity.
I am able to ...
I've been through all the threads on the dependencies for connecting spark running on an aws EMR to an s3 bucket, however my issue seems to be slightly different. In all of the other discussions I ...
Is there any benefit to running Akka apps inside docker containers? How does this affect the app? If there is one Akka microservice per container how does akka keep track of things? Does this mean I ...
I am trying to join a master table with multiple Key-Value Dataframe derived from single Dataframe, Spark is reusing the same lineage Dataframe instead of Cloning multiple instances, Due to which only ...
I have a DF as show below , I need to convert this into sub-Dataframes without using createOrReplaceTempView (and doing sub-queries in sql) as the sub-Dataframes will be used for performing multiple ...
I have a situation where i have list of rows with multiple columns and have to group by with a lookup key which is a unique column in all rows ..
I have to sum up values of a given column (say x) for ...