Java 9 Convenience Factory Methods for Collections
Java 9 enhances the java collections and provides static methods for creating small immutable collection instances.
Combine by key to find max
Use combine by key and use map transformation to find Max value for all the keys in Spark
accumulate all values for a given key in spark
For a given key collect all the values, which can be later use for applying some custom logic like ( average , max , min, top n, expression evaluation) in Spark
Read from Aerospike
Read From Aerospike Using Spark via Map Transformation in Spark
Write To Aerospike From Spark
Read from Hdfs and write to Aerospike from Spark via Map Transformation
MultiKey Map
Java Map interface doesn’t provide possibility to have multiple keys for single entry. Let’s see what are the possible workarounds.
Spark Map Vs mapPartitions
Spark Map Vs mapPartitions