You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@wayang.apache.org by rp...@apache.org on 2022/04/08 18:58:34 UTC
[incubator-wayang] 01/01: Merge pull request #139 from apache/python-platform
This is an automated email from the ASF dual-hosted git repository.
rpardomeza pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit 4cc0bfdca06dda171b661822daae5fa438d9d475
Merge: 70f41b13 3a9de146
Author: Rodrigo Pardo Meza <ro...@gmail.com>
AuthorDate: Fri Apr 8 14:58:28 2022 -0400
Merge pull request #139 from apache/python-platform
WAYANG-8 inclusion of python as platform of processing
.gitignore | 3 +
.licenserc.yaml | 3 +
bin/pyplangenerator.sh | 26 +
pom.xml | 4 +
python/.gitignore | 277 +
python/.rat-excludes | 6 +
python/LICENSE | 203 +
python/README.md | 3 +
python/bin/benchmark.sh | 50 +
python/bin/check-license.sh | 28 +
python/bin/test.sh | 25 +
python/old_code/__init__.py | 16 +
python/old_code/config/config_reader.py | 51 +
python/old_code/config/pywayang_config.ini | 38 +
python/old_code/old_graph/__init__.py | 19 +
python/old_code/old_graph/graph.py | 71 +
python/old_code/old_graph/node.py | 48 +
python/old_code/old_graph/traversal.py | 51 +
python/old_code/old_graph/visitant.py | 52 +
python/old_code/orchestrator/__init__.py | 16 +
python/old_code/orchestrator/dataquanta.py | 330 +
python/old_code/orchestrator/execdirectly.py | 162 +
python/old_code/orchestrator/main.py | 172 +
python/old_code/orchestrator/operator.py | 125 +
python/old_code/orchestrator/plan.py | 53 +
python/old_code/protobuf/__init__.py | 16 +
python/old_code/protobuf/planwriter.py | 276 +
python/old_code/test.py | 115 +
python/old_code/tests/__init__.py | 16 +
python/old_code/tests/demo_testing.py | 31 +
python/old_code/tests/full_java_test.py | 72 +
python/old_code/tests/full_spark_test.py | 63 +
python/pywayang.toml | 20 +
python/resources/test.input | 4 +
python/resources/text.input | 16872 +++++++++++++++++++
python/setup.cfg | 48 +
python/src/pywy/__init__.py | 16 +
python/src/pywy/config.py | 49 +
python/src/pywy/core/__init__.py | 35 +
python/src/pywy/core/channel.py | 45 +
python/src/pywy/core/executor.py | 24 +
python/src/pywy/core/mapping.py | 45 +
python/src/pywy/core/plan.py | 76 +
python/src/pywy/core/platform.py | 38 +
python/src/pywy/core/plugin.py | 51 +
python/src/pywy/core/translator.py | 58 +
python/src/pywy/dataquanta.py | 113 +
python/src/pywy/exception.py | 19 +
python/src/pywy/graph/__init__.py | 16 +
python/src/pywy/graph/graph.py | 89 +
python/src/pywy/graph/types.py | 75 +
python/src/pywy/operators/__init__.py | 31 +
python/src/pywy/operators/base.py | 109 +
python/src/pywy/operators/sink.py | 58 +
python/src/pywy/operators/source.py | 53 +
python/src/pywy/operators/unary.py | 91 +
python/src/pywy/platforms/__init__.py | 16 +
python/src/pywy/platforms/python/__init__.py | 16 +
python/src/pywy/platforms/python/channels.py | 75 +
python/src/pywy/platforms/python/execution.py | 94 +
python/src/pywy/platforms/python/mappings.py | 29 +
.../src/pywy/platforms/python/operator/__init__.py | 32 +
.../python/operator/py_execution_operator.py | 30 +
.../platforms/python/operator/py_sink_textfile.py | 60 +
.../python/operator/py_source_textfile.py | 54 +
.../platforms/python/operator/py_unary_filter.py | 66 +
.../platforms/python/operator/py_unary_flatmap.py | 66 +
.../pywy/platforms/python/operator/py_unary_map.py | 66 +
python/src/pywy/platforms/python/platform.py | 24 +
python/src/pywy/platforms/python/plugin.py | 31 +
python/src/pywy/plugins.py | 27 +
python/src/pywy/tests/__init__.py | 16 +
python/src/pywy/tests/benchmark/__init__.py | 17 +
.../pywy/tests/benchmark/python_benchmark_test.py | 82 +
python/src/pywy/tests/integration/__init__.py | 17 +
.../pywy/tests/integration/python_platform_test.py | 144 +
python/src/pywy/tests/resources/10e0MB.input | 16872 +++++++++++++++++++
python/src/pywy/tests/unit/__init__.py | 16 +
python/src/pywy/tests/unit/core/__init__.py | 16 +
python/src/pywy/tests/unit/core/channel_test.py | 33 +
python/src/pywy/tests/unit/core/executor_test.py | 33 +
python/src/pywy/tests/unit/core/mapping_test.py | 33 +
python/src/pywy/tests/unit/core/plan_test.py | 33 +
python/src/pywy/tests/unit/core/platform_test.py | 31 +
python/src/pywy/tests/unit/core/plugin_test.py | 33 +
python/src/pywy/tests/unit/core/translator_test.py | 33 +
python/src/pywy/tests/unit/dataquanta/__init__.py | 17 +
.../src/pywy/tests/unit/dataquanta/context_test.py | 103 +
.../pywy/tests/unit/dataquanta/dataquanta_test.py | 156 +
python/src/pywy/tests/unit/graph/__init__.py | 16 +
python/src/pywy/tests/unit/graph/graph_test.py | 33 +
python/src/pywy/tests/unit/graph/types_test.py | 33 +
python/src/pywy/tests/unit/operators/__init__.py | 16 +
python/src/pywy/tests/unit/operators/base_test.py | 33 +
python/src/pywy/tests/unit/operators/sink_test.py | 33 +
.../src/pywy/tests/unit/operators/source_test.py | 33 +
python/src/pywy/tests/unit/operators/unary_test.py | 33 +
python/src/pywy/tests/unit/platforms/__init__.py | 16 +
.../pywy/tests/unit/platforms/python/__init__.py | 16 +
.../tests/unit/platforms/python/channel_test.py | 33 +
.../tests/unit/platforms/python/execution_test.py | 33 +
.../tests/unit/platforms/python/mappings_test.py | 33 +
.../unit/platforms/python/operator/__init__.py | 16 +
.../python/operator/py_execution_operator_test.py | 33 +
.../python/operator/py_sink_textfile_test.py | 33 +
.../python/operator/py_source_textfile_test.py | 33 +
.../python/operator/py_unary_filter_test.py | 33 +
.../tests/unit/platforms/python/platform_test.py | 33 +
.../tests/unit/platforms/python/plugin_test.py | 33 +
python/src/pywy/tests/unit/types_test.py | 276 +
python/src/pywy/translate/__init__.py | 16 +
python/src/pywy/types.py | 101 +
112 files changed, 39795 insertions(+)