diff options
| author | Zheng RuiFeng <ruifengz@foxmail.com> | 2016-06-06 09:35:47 +0100 |
|---|---|---|
| committer | Sean Owen <sowen@cloudera.com> | 2016-06-06 09:35:47 +0100 |
| commit | fd8af397132fa1415a4c19d7f5cb5a41aa6ddb27 (patch) | |
| tree | a653b3542d0671c8cb8b3ff7fa3755525c0606a4 /python/pyspark/sql/streaming.py | |
| parent | 32f2f95dbdfb21491e46d4b608fd4e8ac7ab8973 (diff) | |
| download | spark-fd8af397132fa1415a4c19d7f5cb5a41aa6ddb27.tar.gz spark-fd8af397132fa1415a4c19d7f5cb5a41aa6ddb27.tar.bz2 spark-fd8af397132fa1415a4c19d7f5cb5a41aa6ddb27.zip | |
[MINOR] Fix Typos 'an -> a'
## What changes were proposed in this pull request?
`an -> a`
Use cmds like `find . -name '*.R' | xargs -i sh -c "grep -in ' an [^aeiou]' {} && echo {}"` to generate candidates, and review them one by one.
## How was this patch tested?
manual tests
Author: Zheng RuiFeng <ruifengz@foxmail.com>
Closes #13515 from zhengruifeng/an_a.
Diffstat (limited to 'python/pyspark/sql/streaming.py')
| -rw-r--r-- | python/pyspark/sql/streaming.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/sql/streaming.py b/python/pyspark/sql/streaming.py index cd75622ced..580aba651f 100644 --- a/python/pyspark/sql/streaming.py +++ b/python/pyspark/sql/streaming.py @@ -72,7 +72,7 @@ class ContinuousQuery(object): @since(2.0) def processAllAvailable(self): - """Blocks until all available data in the source has been processed an committed to the + """Blocks until all available data in the source has been processed and committed to the sink. This method is intended for testing. Note that in the case of continually arriving data, this method may block forever. Additionally, this method is only guaranteed to block until data that has been synchronously appended data to a stream source prior to invocation. |