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 <[email protected]> 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(+)
