Write To Aerospike via mapPartitions
Write to Aerospike from spark via MapPartitions
Write To Aerospike From Spark
Read from Hdfs and write to Aerospike from Spark via Map Transformation
Read Kafka From Flink
Read Kafka from Flink with Integration Test
Kafka Unit Flink
Kafka Unit For flink (Flink api have lower scala and kafka version ) to write integration Test for flink
Word Count Flink
Word Count in Flink . If you can count on Spark then Flink !!
Kafka Unit framework
Kafka unit test Framework to help in writing Integration Test .
Zookeeper Testing Unit module
For integration test a embedded zookeeper module
Aeorpsike Unit Test Framework
Aerospike Unit Test framework to run test on Aerospike as part of maven module
Convert Avro Object To Row
Avro to Row conversion
Understanding Spark Serialization
Understanding Spark Serialization , and in the process try to understand when to use lambada function , static,anonymous class and transient references