diff options
| author | uncleGen <hustyugm@gmail.com> | 2017-03-12 08:29:37 +0000 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2017-03-12 08:29:37 +0000 |
| commit | e29a74d5b1fa3f9356b7af5dd7e3fce49bc8eb7d (patch) | |
| tree | f1512df30b47dc27f922d175a9d7dc344c6ac29f /streaming | |
| parent | f6fdf92d0dce2cb3340f3e2ff768e09ef69176cd (diff) | |
| download | spark-e29a74d5b1fa3f9356b7af5dd7e3fce49bc8eb7d.tar.gz spark-e29a74d5b1fa3f9356b7af5dd7e3fce49bc8eb7d.tar.bz2 spark-e29a74d5b1fa3f9356b7af5dd7e3fce49bc8eb7d.zip | |
[DOCS][SS] fix structured streaming python example
## What changes were proposed in this pull request?
- SS python example: `TypeError: 'xxx' object is not callable`
- some other doc issue.
## How was this patch tested?
Jenkins.
Author: uncleGen <hustyugm@gmail.com>
Closes #17257 from uncleGen/docs-ss-python.
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/dstream/FileInputDStream.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/dstream/FileInputDStream.scala b/streaming/src/main/scala/org/apache/spark/streaming/dstream/FileInputDStream.scala index ed9305875c..905b1c52af 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/dstream/FileInputDStream.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/dstream/FileInputDStream.scala @@ -230,7 +230,7 @@ class FileInputDStream[K, V, F <: NewInputFormat[K, V]]( * - It must pass the user-provided file filter. * - It must be newer than the ignore threshold. It is assumed that files older than the ignore * threshold have already been considered or are existing files before start - * (when newFileOnly = true). + * (when newFilesOnly = true). * - It must not be present in the recently selected files that this class remembers. * - It must not be newer than the time of the batch (i.e. `currentTime` for which this * file is being tested. This can occur if the driver was recovered, and the missing batches |