diff options
| author | Shixiong Zhu <shixiong@databricks.com> | 2016-04-05 11:12:05 -0700 |
|---|---|---|
| committer | Michael Armbrust <michael@databricks.com> | 2016-04-05 11:12:05 -0700 |
| commit | 463bac001171622538fc93d2e31d1a617ab562e6 (patch) | |
| tree | 406a34b25c2955a070153db16cca5b3b8f31161a /yarn | |
| parent | f77f11c67125fdac2e6849a4d45d9286fc872ed9 (diff) | |
| download | spark-463bac001171622538fc93d2e31d1a617ab562e6.tar.gz spark-463bac001171622538fc93d2e31d1a617ab562e6.tar.bz2 spark-463bac001171622538fc93d2e31d1a617ab562e6.zip | |
[SPARK-14257][SQL] Allow multiple continuous queries to be started from the same DataFrame
## What changes were proposed in this pull request?
Make StreamingRelation store the closure to create the source in StreamExecution so that we can start multiple continuous queries from the same DataFrame.
## How was this patch tested?
`test("DataFrame reuse")`
Author: Shixiong Zhu <shixiong@databricks.com>
Closes #12049 from zsxwing/df-reuse.
Diffstat (limited to 'yarn')
0 files changed, 0 insertions, 0 deletions