ayushprashar

import java.util.*;

public class InstrumentedSet<T> extends ForwardingSet<T> {
	private static int insertionCount;

	public InstrumentedSet(Set<T> s) {
		super(s);
	}

	@Override

ayushprashar

import java.util.*;

public class ForwardingSet<T> implements Set<T> {

	private final Set<T> set;
	
	ForwardingSet(Set<T> set) {
		this.set = set;	
	}

ayushprashar

Question 1
scala> val line = "Hello, World"
line: String = Hello, World
scala> val rdd = sc.parallelize(List(line))
rdd: org.apache.spark.rdd.RDD[String] = ParallelCollectionRDD[0] at parallelize at <console>:26
scala> rdd.collect
res2: Array[String] = Array(Hello, World)                                       

Question 2
scala> val rdd = sc.parallelize(List(1,1,2,3,4,4))