-
Notifications
You must be signed in to change notification settings - Fork 28.6k
[SPARK-18192] Support all file formats in structured streaming #15711
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
Test build #67875 has finished for PR 15711 at commit
|
Test build #67876 has finished for PR 15711 at commit
|
LGTM pending tests |
Test build #3391 has finished for PR 15711 at commit
|
Test build #67943 has finished for PR 15711 at commit
|
@marmbrus I ended up adding test cases since they were trivial to add (and an existing test case was asserting that text would not be supported). |
Test build #3392 has finished for PR 15711 at commit
|
Test build #67952 has finished for PR 15711 at commit
|
Merging in master/branch-2.1 |
## What changes were proposed in this pull request? This patch adds support for all file formats in structured streaming sinks. This is actually a very small change thanks to all the previous refactoring done using the new internal commit protocol API. ## How was this patch tested? Updated FileStreamSinkSuite to add test cases for json, text, and parquet. Author: Reynold Xin <rxin@databricks.com> Closes #15711 from rxin/SPARK-18192. (cherry picked from commit a36653c) Signed-off-by: Reynold Xin <rxin@databricks.com>
## What changes were proposed in this pull request? This patch adds support for all file formats in structured streaming sinks. This is actually a very small change thanks to all the previous refactoring done using the new internal commit protocol API. ## How was this patch tested? Updated FileStreamSinkSuite to add test cases for json, text, and parquet. Author: Reynold Xin <rxin@databricks.com> Closes apache#15711 from rxin/SPARK-18192.
What changes were proposed in this pull request?
This patch adds support for all file formats in structured streaming sinks. This is actually a very small change thanks to all the previous refactoring done using the new internal commit protocol API.
How was this patch tested?
Updated FileStreamSinkSuite to add test cases for json, text, and parquet.