GitHub user joseph-torres opened a pull request:
https://github.com/apache/spark/pull/19926
[SPARK-22733] Split StreamExecution into MicroBatchExecution and
StreamExecution.
## What changes were proposed in this pull request?
StreamExecution is now an abstract base class, which MicroBatchExecution
(the current StreamExecution) inherits. When continuous processing is
implemented, we'll have a new ContinuousExecution implementation of
StreamExecution.
A few fields are also renamed to make them less microbatch-specific.
## How was this patch tested?
refactoring only
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/joseph-torres/spark continuous-refactor
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/spark/pull/19926.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #19926
----
commit 22d93b7d6133bffb271e6db300b936ae4dda74ab
Author: Jose Torres <[email protected]>
Date: 2017-12-07T22:08:28Z
Refactor StreamExecution into a parent class so continuous processing can
extend it
----
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
