CODEWITHSUNDEEP
javascalaclassapache-spark
spark_user
spark_user

Reputation: 97

Creating a Java Object in Scala

I have a Java class "Listings". I use this in my Java MapReduce job as below:

public void map(Object key, Text value, Context context) throws IOException, InterruptedException {
Listings le = new Listings(value.toString());
...
}

I want to run the same job on Spark. So, I am writing this in Scala now. I imported the Java class:

import src.main.java.lists.Listings

I want to create a Listings object in Scala. I am doing this:

val file_le = sc.textFile("file// Path to file")
Listings lists = new Listings(file_le)

I get an error:

value lists is not a member of object src.main.java.lists.Listings

What is the right way to do this?

Upvotes: 4

Views: 10452

Answers (1)

childofsoong
childofsoong

Reputation: 1936

Based on what you've said, I think you may be forgetting the differences between Scala syntax and Java syntax.

Try this:

val lists: Listings = new Listings(SomeString)

Please note that specifying the type in Scala is completely optional. Also, use a var if you're going to be changing the value of lists.

The way you have it, Scala is trying to interpret it by its ability to call methods/access values of an object without the '.', so you're actually telling Scala this:

Listings.lists = new Listings(SomeString)

Upvotes: 4

Related Questions