Avro serialization de-serialization using Confluent Schema registry
Avro serialization de-serialization using Confluent Schema registry
How is BigData Used
Where is Big Data used and how has the architecture of systems evolved in the light of Big Data
ReduceByKey vs CombineByKey
Whats the difference between reduceByKey and CombineByKey in Spark
GroupBy vs ReduceByKey
Whats the difference between groupByKey vs ReduceByKey in Spark
Combine by key to find max
Use combine by key and use map transformation to find Max value for all the keys in Spark
group by key
Group by key and in the Map Partition apply some custom logic on the aggregated values of the key 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 Kafka and Write To Aerospike from Flink
Read from Kafka And write to Aerospike through flink.
Read from Aerospike from Spark via MapPartitions
Read from Aerospike with a spark application via mapPartitions in Spark
Read from Aerospike
Read From Aerospike Using Spark via Map Transformation in Spark