(final Configuration mrConfig)
| 26 | public final class WritableUtils { |
| 27 | |
| 28 | public static final Job newJob(final Configuration mrConfig) throws IOException { |
| 29 | //// Hadoop 0.20.2 way of doing this (works in 0.21.0, used in their examples but depreciated) |
| 30 | /// @SuppressWarnings("deprecation") |
| 31 | final Job job = new Job(mrConfig); |
| 32 | //// Hadoop 0.21.0 way of doing this |
| 33 | // final Cluster clus = new Cluster(mrConfig); |
| 34 | //final Job job = Job.getInstance(clus,mrConfig); |
| 35 | return job; |
| 36 | } |
| 37 | |
| 38 | public static String readFirstLine(final Configuration mrConfig, final Path pathIn) throws IOException { |
| 39 | final FSDataInputStream fdi = pathIn.getFileSystem(mrConfig).open(pathIn); |
no outgoing calls
no test coverage detected