Skip to content

Commit

Permalink
feat(jogasaki): add scan_range to enable parallelization
Browse files Browse the repository at this point in the history
  • Loading branch information
@YoshiakiNishimura
YoshiakiNishimura committed Nov 13, 2024
1 parent 7f902c4 commit db24013
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion jogasaki
Submodule jogasaki updated 35 files
+2 −2 examples/process_cli/main.cpp
+2 −4 mock/jogasaki/executor/process/mock/task_context.cpp
+7 −9 mock/jogasaki/executor/process/mock/task_context.h
+19 −2 src/jogasaki/data/aligned_buffer.cpp
+9 −2 src/jogasaki/data/aligned_buffer.h
+12 −14 src/jogasaki/executor/process/abstract/range.h
+9 −11 src/jogasaki/executor/process/abstract/task_context.h
+3 −3 src/jogasaki/executor/process/flow.cpp
+33 −0 src/jogasaki/executor/process/impl/bound.cpp
+52 −0 src/jogasaki/executor/process/impl/bound.h
+29 −1 src/jogasaki/executor/process/impl/ops/details/encode_key.cpp
+28 −0 src/jogasaki/executor/process/impl/ops/details/encode_key.h
+44 −44 src/jogasaki/executor/process/impl/ops/operator_builder.cpp
+10 −21 src/jogasaki/executor/process/impl/ops/operator_builder.h
+7 −8 src/jogasaki/executor/process/impl/ops/operator_container.cpp
+9 −11 src/jogasaki/executor/process/impl/ops/operator_container.h
+16 −68 src/jogasaki/executor/process/impl/ops/scan.cpp
+2 −7 src/jogasaki/executor/process/impl/ops/scan.h
+6 −14 src/jogasaki/executor/process/impl/ops/scan_context.cpp
+5 −9 src/jogasaki/executor/process/impl/ops/scan_context.h
+4 −4 src/jogasaki/executor/process/impl/processor.cpp
+4 −6 src/jogasaki/executor/process/impl/processor.h
+0 −53 src/jogasaki/executor/process/impl/scan_info.cpp
+0 −63 src/jogasaki/executor/process/impl/scan_info.h
+38 −0 src/jogasaki/executor/process/impl/scan_range.cpp
+49 −0 src/jogasaki/executor/process/impl/scan_range.h
+8 −8 src/jogasaki/executor/process/impl/task_context.cpp
+8 −10 src/jogasaki/executor/process/impl/task_context.h
+36 −0 src/jogasaki/kvs/storage.cpp
+27 −3 src/jogasaki/kvs/storage.h
+4 −5 test/jogasaki/executor/process/ops/join_find_test.cpp
+45 −29 test/jogasaki/executor/process/ops/scan_test.cpp
+4 −5 test/jogasaki/executor/process/process_executor_test.cpp
+4 −5 test/jogasaki/executor/process/processor_test.cpp
+3 −3 test/jogasaki/operator_test_utils.h

0 comments on commit db24013

Please sign in to comment.