Suppose there are two folders A and B. A folder will be loaded with Employee data files and B folder will be loaded with Department data files.
Every minute, the java program should monitor these folders and trigger SparkA(based on folder A) or SparkB(based on folder B) programs(Spark-Submit or equivalent). After successful completion, the java program should move the processed files to a different location. The condition is either for every five minutes or for exceeding the size of the folder to more than 2GB.(Spark 2.1.1)
You can use below code for reference:
[url removed, login to view]
Run the spark job(spark-submit) from java code.
Schedule the java class based on time or size, whatever matches first. (Configurable size or configurable time)
Java class should read the files in the folder and move them to a different folder and Spark job will read the files from this new folder.
6 freelanceria on tarjonnut keskimäärin %project_bid_stats_avg_sub_26% %project_currencyDetails_sign_sub_27% tähän työhön
Hello, dear How are you? I have experience in Hadoop in pyspark with python. I think that i can help you as well. Hope your contact me. Best Regards.
Hi, I have more that 4+years of experience in hadoop and data mining technologies like HDFS, MapReduce, python, Spark, Hive etc. Please review my profile for skills Contact me