This is an automated email from the ASF dual-hosted git repository. quiaru pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit 77a5d3b5854f59b9cad1f9e9921b849ccc5cca58 Merge: b2a202f1 f738e66f Author: Jorge Quiane <[email protected]> AuthorDate: Tue Apr 12 23:37:44 2022 +0200 Merge pull request #212 from apache/wayang-211 JVM-platform inside of Python-API python/src/pywy/core/__init__.py | 4 +- python/src/pywy/core/channel.py | 52 +++++- python/src/pywy/core/core.py | 174 +++++++++++++++++++++ python/src/pywy/core/executor.py | 11 ++ python/src/pywy/core/mapping.py | 42 ++++- python/src/pywy/core/plan.py | 76 --------- python/src/pywy/core/plugin.py | 51 ------ python/src/pywy/core/translator.py | 58 ------- python/src/pywy/dataquanta.py | 12 +- python/src/pywy/operators/base.py | 4 +- .../executor.py => platforms/commons/__init__.py} | 10 +- .../pywy/platforms/{python => commons}/channels.py | 34 ++-- .../executor.py => platforms/jvm/__init__.py} | 8 - python/src/pywy/platforms/jvm/channels.py | 47 ++++++ .../{core/executor.py => platforms/jvm/context.py} | 17 +- python/src/pywy/platforms/jvm/execution.py | 93 +++++++++++ python/src/pywy/platforms/jvm/graph.py | 52 ++++++ .../executor.py => platforms/jvm/mappings.py} | 12 +- .../{core => platforms/jvm/operator}/__init__.py | 23 +-- .../jvm/operator/jvm_execution_operator.py} | 43 ++--- .../operator/jvm_sink_textfile.py} | 46 +++--- .../operator/jvm_source_textfile.py} | 32 ++-- .../platforms/jvm/operator/jvm_unary_filter.py | 73 +++++++++ .../executor.py => platforms/jvm/platform.py} | 10 +- .../{core/executor.py => platforms/jvm/plugin.py} | 16 +- .../jvm/serializable/__init__.py} | 8 - .../platforms/jvm/serializable/plan_writter.py | 131 ++++++++++++++++ .../jvm/serializable/wayang_jvm_operator.py | 114 ++++++++++++++ python/src/pywy/platforms/python/channels.py | 40 +---- .../platforms/python/operator/py_sink_textfile.py | 5 +- .../python/operator/py_source_textfile.py | 7 +- .../platforms/python/operator/py_unary_filter.py | 29 ++-- .../platforms/python/operator/py_unary_flatmap.py | 29 ++-- .../pywy/platforms/python/operator/py_unary_map.py | 29 ++-- python/src/pywy/plugins.py | 2 + .../pywy/tests/integration/jvm_platform_test.py | 143 +++++++++++++++++ 36 files changed, 1097 insertions(+), 440 deletions(-)
