Skip to content

Commit

Permalink
fixed a single slightly over 100 character line
Browse files Browse the repository at this point in the history
  • Loading branch information
kmader committed Oct 21, 2014
1 parent 92bda0d commit 8ac288b
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -260,7 +260,8 @@ class JavaSparkContext(val sc: SparkContext) extends JavaSparkContextVarargsWork
JavaPairRDD[String,PortableDataStream] = new JavaPairRDD(sc.binaryFiles(path,minPartitions))

def binaryFiles(path: String):
JavaPairRDD[String,PortableDataStream] = new JavaPairRDD(sc.binaryFiles(path,defaultMinPartitions))
JavaPairRDD[String,PortableDataStream] =
new JavaPairRDD(sc.binaryFiles(path,defaultMinPartitions))

/**
* Read a directory of files as DataInputStream from HDFS,
Expand Down

0 comments on commit 8ac288b

Please sign in to comment.