Skip to content

Commit 188f4e1

Browse files
committed
add
1 parent b85c7fe commit 188f4e1

1 file changed

Lines changed: 1 addition & 1 deletion

File tree

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@ import org.apache.spark.util.{TimeStampedHashMap, Utils}
3535
*
3636
* At each batch interval, Use `depth` to find files in the directory recursively,
3737
* the file system is queried for files in the given directory and detected new
38-
* files are selected for that batch. if the `depth` is greater than 1,
38+
* files are selected for that batch. If the `depth` is greater than 1,
3939
* it is queried for files in the depth of the recursion, In this case "new" means files that
4040
* became visible to readers during that time period. Some extra care is needed to deal
4141
* with the fact that files may become visible after they are created. For this purpose, this

0 commit comments

Comments
 (0)