MRFramework/src/main/java/com/mr/net/Node.java
/**
	 * reads file from bucket and for each row, calls the mapper's map function
	 * Output is added to the localData 
	 * 
	 * @param bucket
	 * @param file : mapper file to read 
	 * @throws IOException
	 */
reads file from bucket and for each row, calls the mapper's map function
Output is added to the localData

@param bucket
@param file : mapper file to read
@throws IOException
reads file from bucket and for each row calls the mapper ' s map function Output is added to the localData @param bucket @param file : mapper file to read @throws IOException
private void readS3FileContentsAndCallMapper(String bucket, String file) throws IOException {
		S3Object s3o = App.s3.getObject(new GetObjectRequest(bucket,file));
		BufferedReader reader=new BufferedReader(new InputStreamReader(s3o.getObjectContent()));
		String line=null;
		Integer lineNum = 0;
		while((line=reader.readLine()) != null){
			Tuple<KEY, VALUE> record = new Tuple<>();
			record.setKey((KEY) lineNum++);
			record.setValue((VALUE) line);
			mapper.map(localData, record);
		}
		reader.close();
	}
private void readS3FileContentsAndCallMapper ( String bucket , String file ) throws IOException { S3Object s3o = App . s3 . getObject ( new GetObjectRequest ( bucket , file ) ) ; BufferedReader reader = new BufferedReader ( new InputStreamReader ( s3o . getObjectContent ( ) ) ) ; String line = null ; Integer lineNum = 0 ; while ( ( line = reader . readLine ( ) ) != null ) { Tuple < KEY , VALUE > record = new Tuple < > ( ) ; record . setKey ( ( KEY ) lineNum ++ ) ; record . setValue ( ( VALUE ) line ) ; mapper . map ( localData , record ) ; } reader . close ( ) ; }
reads file from bucket and for each row, calls the mapper's map function
 Output is added to the localData
reads file from bucket and for each row calls the mapper ' s map function Output is added to the localData