Skip to content

Commit 178066f

Browse files
committed
modify code's style. [Exceeds 100 columns]
1 parent 626ef97 commit 178066f

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

streaming/src/main/scala/org/apache/spark/streaming/dstream/FileInputDStream.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -120,7 +120,8 @@ class FileInputDStream[K: ClassTag, V: ClassTag, F <: NewInputFormat[K,V] : Clas
120120

121121
/** Generate one RDD from an array of files */
122122
private def filesToRDD(files: Seq[String]): RDD[(K, V)] = {
123-
val fileRDDs = for (file <- files; rdd = context.sparkContext.newAPIHadoopFile[K, V, F](file)) yield {
123+
val fileRDDs = for (file <- files; rdd = context.sparkContext.newAPIHadoopFile[K, V, F](file))
124+
yield {
124125
if (rdd.partitions.size == 0) {
125126
logError("File " + file + " has no data in it. Spark Streaming can only ingest " +
126127
"files that have been \"moved\" to the directory assigned to the file stream. " +

0 commit comments

Comments
 (0)