scale-up#103

Open

galsalomon66 wants to merge 7 commits intomasterfrom

Commits on Sep 4, 2022

adding capability to execute the same query across different input-stream(CSV in this case), and to merge results of each of the streams and return it to caller as a single one. the different exec…
galsalomon66
committed
oops
galsalomon66
committed

Commits on Sep 5, 2022

adding the aggregation flow for scale-up processing. each aggregation node (sum,max ...) has 2 state to handle, first-phase(processing query), second-phase(aggregate results of all participants).
galsalomon66
committed
adding csv_streamer to enable the processing of a single query on multiple execution flows for aggregation and non aggregation flow. bug fixes.
galsalomon66
committed
bug fix. add pthread to scaleup app
galsalomon66
committed
adding spiliting functionality. i.e. spliting an input into equal parts to be processed simultaneously
galsalomon66
committed
rebase. adding json flow
galsalomon66
committed