public void load_source_json(String src_json_file_path,
			                     String app_load_file_path){
		 try{
		    JsonFactory f = new JsonFactory();
	        JsonParser jp = f.createParser(new File(src_json_file_path));
	        ObjectMapper mapper = new ObjectMapper(); 
	        String type = null;
	        File f_applod = new File(app_load_file_path);
	        JsonGenerator jf_appl = mapper.getFactory().createGenerator(new BufferedWriter(new FileWriter(f_applod, true)));
	        int LoadCounter     = 0;
	        int AnyCounter      = 0;
	        int TotalEventsCnt  = 0;
	       
	        while(jp.nextToken() == JsonToken.START_OBJECT) {

	        	  TreeNode node = mapper.readTree(jp);
	        	  TotalEventsCnt++;

	        	    if (node.get("_n").toString().equals("\"aloaded\"")) {	
	        	    	LoadCounter++;
	        	    	mapper.writeValue(jf_appl, node);
	        	    }  else {
	        	    	AnyCounter++;	
	        	    }
              
	        	}
	    	logger.info("LoadCounter     = "+String.valueOf(LoadCounter));
	    	logger.info("AnyCounter      = "+String.valueOf(AnyCounter));
	    	logger.info("TotalEvents     = "+String.valueOf(TotalEventsCnt));
	    	jf_appl.close();

		 } 
	     catch (IOException e) {
		  logger.error(e.fillInStackTrace());
		 }
	}

jf_appl.setPrettyPrinter(new MinimalPrettyPrinter(""));

SparkSession spark = SparkSession
.builder()
.appName("Java Spark SQL basic example")
.config("spark.master", "local[*]")
.getOrCreate();

Dataset<Row> df = spark.read().schema(buildSchemaAppLoaded()).json(js_fpath);

df.printSchema();
df.show();

	        MinimalPrettyPrinter pp = new MinimalPrettyPrinter(); 
	        pp.setRootValueSeparator("\n"); 
	        jf_appl.setPrettyPrinter(pp);