Advertisement
Guest User

Untitled

a guest
Nov 23rd, 2014
120
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.34 KB | None | 0 0
  1. package mapreduce;
  2.  
  3. import java.io.*;
  4.  
  5. public class MapReduce
  6. {
  7. private static int threadNumber;
  8. private static String inputFile;
  9. private static String outputFile;
  10.  
  11. private static Mapper fileMapper;
  12.  
  13. public static void processDocuments()
  14. {
  15. try
  16. {
  17. BufferedReader reader = new BufferedReader(new FileReader(inputFile));
  18.  
  19. int fragmentSize = Integer.parseInt(reader.readLine());
  20. float similarityMargin = Float.parseFloat(reader.readLine());
  21. int fileNumber = Integer.parseInt(reader.readLine());
  22.  
  23. for(int i=1;i<=fileNumber;i++)
  24. {
  25. String fileName = reader.readLine();
  26.  
  27. fileMapper = new Mapper(fileName, fragmentSize, similarityMargin, threadNumber);
  28.  
  29. fileMapper.MapFragments();
  30. }
  31. }
  32. catch(Exception e)
  33. {
  34. System.out.println(e.getMessage());
  35. }
  36. }
  37.  
  38. public static void main(String[] args)
  39. {
  40. threadNumber = Integer.parseInt(args[0]);
  41. inputFile = args[1];
  42. outputFile = args[2];
  43.  
  44. processDocuments();
  45.  
  46. System.out.print(threadNumber + " " + inputFile + " " + outputFile);
  47.  
  48. }
  49. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement