Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package mapreduce;
- import java.io.*;
- public class MapReduce
- {
- private static int threadNumber;
- private static String inputFile;
- private static String outputFile;
- private static Mapper fileMapper;
- public static void processDocuments()
- {
- try
- {
- BufferedReader reader = new BufferedReader(new FileReader(inputFile));
- int fragmentSize = Integer.parseInt(reader.readLine());
- float similarityMargin = Float.parseFloat(reader.readLine());
- int fileNumber = Integer.parseInt(reader.readLine());
- for(int i=1;i<=fileNumber;i++)
- {
- String fileName = reader.readLine();
- fileMapper = new Mapper(fileName, fragmentSize, similarityMargin, threadNumber);
- fileMapper.MapFragments();
- }
- }
- catch(Exception e)
- {
- System.out.println(e.getMessage());
- }
- }
- public static void main(String[] args)
- {
- threadNumber = Integer.parseInt(args[0]);
- inputFile = args[1];
- outputFile = args[2];
- processDocuments();
- System.out.print(threadNumber + " " + inputFile + " " + outputFile);
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement