Hi,
I am loading data from Hive table to Hbase after doing some manipulation.
I am getting error as 'Task not Serializable'.
My code is as below.
public class HiveToHbaseLoader implements Serializable {
public static void main(String[] args) throws Exception {
String hbaseTableNam
Hi,
I got strange behavior. When I am creating schema RDD for nested directory
sometimes it work and sometime it does not work. My question is whether
nested directory supported or not?
My code is as below.
val fileLocation = "hdfs://localhost:9000/apps/hive/warehouse/hl7"
val parquetRDD = sq
Below is code I have written. I am getting NotSerializableException. How
can I handle this scenario?
kafkaStream.foreachRDD(rdd => {
println("")
rdd.foreachPartition(partitionOfRecords => {
partitionOfRecords.foreach(
record => {
