This project aims to make writing Spark applications easier by abstracting the effort to assemble the driver into reusable steps and pipelines.
15
stars
11
forks
source link
Added FlowUtils.readStream step to allow windowing data from a source to a pipeline #374
Closed
dafreels closed 1 year ago