(Path path, Job job)
| 480 | } |
| 481 | |
| 482 | private void setCompression(Path path, Job job) { |
| 483 | String location=path.getName(); |
| 484 | if (location.endsWith(".bz2") || location.endsWith(".bz")) { |
| 485 | FileOutputFormat.setCompressOutput(job, true); |
| 486 | FileOutputFormat.setOutputCompressorClass(job, BZip2Codec.class); |
| 487 | } else if (location.endsWith(".gz")) { |
| 488 | FileOutputFormat.setCompressOutput(job, true); |
| 489 | FileOutputFormat.setOutputCompressorClass(job, GzipCodec.class); |
| 490 | } else { |
| 491 | FileOutputFormat.setCompressOutput( job, false); |
| 492 | } |
| 493 | } |
| 494 | |
| 495 | @Override |
| 496 | public void checkSchema(ResourceSchema s) throws IOException { |
no test coverage detected