1cc66a072b
## What changes were proposed in this pull request? Add a memory source for continuous processing. Note that only one of the ContinuousSuite tests is migrated to minimize the diff here. I'll submit a second PR for SPARK-23688 to change the rest and get rid of waitForRateSourceTriggers. ## How was this patch tested? unit test Author: Jose Torres <torres.joseph.f+github@gmail.com> Closes #20828 from jose-torres/continuousMemory. |
||
---|---|---|
.. | ||
benchmarks | ||
src | ||
pom.xml |