Searched refs:compressedOutputDir (Results 1 – 1 of 1) sorted by relevance
70 val compressedOutputDir = new File(tempDir, "output_compressed").getAbsolutePath constant75 data.saveAsTextFile(compressedOutputDir, classOf[DefaultCodec])81 val compressedFile = new File(compressedOutputDir, "part-00000" + codec.getDefaultExtension)82 val compressedContent = sc.textFile(compressedOutputDir).collect101 val compressedOutputDir = new File(tempDir, "output_compressed").getAbsolutePath constant106 data.saveAsSequenceFile(compressedOutputDir, Some(classOf[DefaultCodec]))112 val compressedFile = new File(compressedOutputDir, "part-00000" + codec.getDefaultExtension)113 val compressedContent = sc.sequenceFile[String, String](compressedOutputDir).collect