incubator-wayang
incubator-wayang copied to clipboard
Apache Wayang(incubating) is the first cross-platform data processing system.
Validate FlinkReduceByOperator implementation it is required to validate the implementation of FlinkReduceByOperator because trigger an exception in the test and looks like is a problem in the implementation of the...
Validate FlinkJoinOperator implementation it is required to validate the implementation of FlinkJoinOperator because trigger an exception in the test and looks like is a problem in the implementation of the...
check for the case where the index matter https://github.com/apache/incubator-wayang/blob/77a5d3b5854f59b9cad1f9e9921b849ccc5cca58/python/src/pywy/platforms/jvm/operator/jvm_unary_filter.py#L61 ```python # # Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE...
check for the case where the index matter https://github.com/apache/incubator-wayang/blob/77a5d3b5854f59b9cad1f9e9921b849ccc5cca58/python/src/pywy/platforms/jvm/operator/jvm_unary_filter.py#L61 ```python # # Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE...
validate if is valite for several output https://github.com/apache/incubator-wayang/blob/77a5d3b5854f59b9cad1f9e9921b849ccc5cca58/python/src/pywy/platforms/jvm/execution.py#L80 ```python # # Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE file...
validate if is valite for several output https://github.com/apache/incubator-wayang/blob/77a5d3b5854f59b9cad1f9e9921b849ccc5cca58/python/src/pywy/platforms/jvm/execution.py#L80 ```python # # Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements. See the NOTICE file...
get this information by a configuration and ideally by the context https://github.com/apache/incubator-wayang/blob/77a5d3b5854f59b9cad1f9e9921b849ccc5cca58/python/src/pywy/platforms/jvm/execution.py#L35 ```python # # Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements....
get this information by a configuration and ideally by the context https://github.com/apache/incubator-wayang/blob/77a5d3b5854f59b9cad1f9e9921b849ccc5cca58/python/src/pywy/platforms/jvm/execution.py#L35 ```python # # Licensed to the Apache Software Foundation (ASF) under one or more # contributor license agreements....
enrich this documentation A plugin contributes the following components to a :class:`Context` - mappings - channels - configurations In turn, it may require several :clas:`Platform`s for its operation. https://github.com/apache/incubator-wayang/blob/77a5d3b5854f59b9cad1f9e9921b849ccc5cca58/python/src/pywy/core/core.py#L35 ```python...
enrich this documentation A plugin contributes the following components to a :class:`Context` - mappings - channels - configurations In turn, it may require several :clas:`Platform`s for its operation. https://github.com/apache/incubator-wayang/blob/77a5d3b5854f59b9cad1f9e9921b849ccc5cca58/python/src/pywy/core/core.py#L35 ```python...