@@ -224,10 +224,10 @@ class FileSuite extends FunSuite with LocalSparkContext {
224224 assert(output.map(_.toString).collect().toList === List (" (1,a)" , " (2,aa)" , " (3,aaa)" ))
225225 }
226226
227- test(" byte stream input" ) {
227+ test(" binary file input as byte array " ) {
228228 sc = new SparkContext (" local" , " test" )
229- val outputDir = new File (tempDir, " output " ).getAbsolutePath
230- val outFile = new File (outputDir, " part -00000.bin" )
229+ val outputDir = new File (tempDir).getAbsolutePath
230+ val outFile = new File (outputDir, " record-bytestream -00000.bin" )
231231 val outFileName = outFile.toPath().toString()
232232
233233 // create file
@@ -248,13 +248,13 @@ class FileSuite extends FunSuite with LocalSparkContext {
248248 assert(indata === testOutput)
249249 }
250250
251- test(" fixed length byte stream input " ) {
251+ test(" fixed record length binary file as byte array " ) {
252252 // a fixed length of 6 bytes
253253
254254 sc = new SparkContext (" local" , " test" )
255255
256- val outputDir = new File (tempDir, " output " ).getAbsolutePath
257- val outFile = new File (outputDir, " part -00000.bin" )
256+ val outputDir = new File (tempDir).getAbsolutePath
257+ val outFile = new File (outputDir, " record-bytestream -00000.bin" )
258258 val outFileName = outFile.toPath().toString()
259259
260260 // create file
0 commit comments