|
Up
|
|
|
|
|
config/
|
— |
|
|
|
default_config/
|
— |
|
|
|
proto/
|
— |
|
|
|
BUILD
|
|
|
|
|
environment_variable_pipeline.pbtxt
|
|
|
|
|
environment_variable_pipeline_integration_test.py
|
|
|
|
|
example_pipeline.pbtxt
|
|
|
|
|
example_pipeline_config.pbtxt
|
|
|
|
|
example_pipeline_integration_test.py
|
|
|
|
|
example_pipeline_py.pbtxt
|
|
|
|
|
finalization_stage.cpp
|
|
|
|
|
finalization_stage.h
|
|
|
|
|
loading_stage.cpp
|
|
|
|
|
loading_stage.h
|
|
|
|
|
loading_stage.py
|
|
|
|
|
map_sort_stage.cpp
|
|
|
|
|
map_sort_stage.h
|
|
|
|
|
map_sort_stage.py
|
|
|
|
|
mean_stage.cpp
|
|
|
|
|
mean_stage.h
|
|
|
|
|
mean_stage.py
|
|
|
|
|
pipeline.png
|
|
|
|
|
reduce_merge_stage.cpp
|
|
|
|
|
reduce_merge_stage.h
|
|
|
|
|
reduce_merge_stage.py
|
|
|
|
|
report_checker.cpp
|
|
|
|
|
report_checker.h
|
|
|
|
|
report_checker.py
|
|
|
|
|
shuffle_stage.cpp
|
|
|
|
|
shuffle_stage.h
|
|
|
|
|
shuffle_stage.py
|
|
|
|
|
std_dev_stage.cpp
|
|
|
|
|
std_dev_stage.h
|
|
|
|
|
std_dev_stage.py
|
|
|
|
|
sum_and_mean_stage.cpp
|
|
|
|
|
sum_and_mean_stage.h
|
|
|
|
|
sum_stage.cpp
|
|
|
|
|
sum_stage.h
|
|
|
|
|
sum_stage.py
|
|
|
|
|
wrong_omp_threads_pipeline.pbtxt
|
|
|
|