incubator-wayang
incubator-wayang copied to clipboard
apache
Apache Wayang(incubating) is the first cross-platform data processing system.
add unitary test to the elements in the file org.apache.wayang.api.JavaPlanBuilder.scala https://github.com/apache/incubator-wayang/blob/278cbdc4bd8e87863a7cb43bc68c52ca783039c0/wayang-api/wayang-api-scala-java/code/main/scala/org/apache/wayang/api/JavaPlanBuilder.scala#L21 ```scala */ package org.apache.wayang.api /** * TODO: add unitary test to the elements in the file org.apache.wayang.api.JavaPlanBuilder.scala * labels:...
![github-actions[bot] avatar](https://avatars.githubusercontent.com/in/15368?v=4 "github-actions[bot] avatar"){kind=avatar}
add unitary test to the elements in the file org.apache.wayang.api.DataQuantaBuilder.scala https://github.com/apache/incubator-wayang/blob/278cbdc4bd8e87863a7cb43bc68c52ca783039c0/wayang-api/wayang-api-scala-java/code/main/scala/org/apache/wayang/api/DataQuantaBuilder.scala#L22 ```scala package org.apache.wayang.api /** * TODO: add unitary test to the elements in the file org.apache.wayang.api.DataQuantaBuilder.scala * labels: unitary-test,todo...
add the documentation to the object org.apache.wayang.api.DataQuanta https://github.com/apache/incubator-wayang/blob/278cbdc4bd8e87863a7cb43bc68c52ca783039c0/wayang-api/wayang-api-scala-java/code/main/scala/org/apache/wayang/api/DataQuanta.scala#L932 ```scala } /** * TODO: add the documentation to the object org.apache.wayang.api.DataQuanta * labels: documentation,todo */ object DataQuanta { def create[T](output: OutputSlot[T])(implicit...
add unitary test to the elements in the file org.apache.wayang.api.DataQuanta.scala https://github.com/apache/incubator-wayang/blob/278cbdc4bd8e87863a7cb43bc68c52ca783039c0/wayang-api/wayang-api-scala-java/code/main/scala/org/apache/wayang/api/DataQuanta.scala#L22 ```scala package org.apache.wayang.api /** * TODO: add unitary test to the elements in the file org.apache.wayang.api.DataQuanta.scala * labels: unitary-test,todo...
This PRs description can be found in one of our blog posts: https://wayang.apache.org/blog/wayang-python-api
Add more estimator mixins https://github.com/apache/incubator-wayang/blob/b67b404ed7cc3349991844ab6b7b5c4af29c2574/wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/EstimatorMixIns.scala#L115 ```scala /* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with...
Is this okay? https://github.com/apache/incubator-wayang/blob/b67b404ed7cc3349991844ab6b7b5c4af29c2574/wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/mixins/ConfigurationAndContextMixIns.scala#L49 ```scala /* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this...
Add all platforms https://github.com/apache/incubator-wayang/blob/b67b404ed7cc3349991844ab6b7b5c4af29c2574/wayang-api/wayang-api-scala-java/src/main/scala/org/apache/wayang/api/serialization/customserializers/PlatformDeserializer.scala#L35 ```scala /* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file * distributed with this...
Check hard coded output index 0 operator.asInstanceOf[OperatorBase].setCardinalityEstimator(0, cardinalityEstimator) // Add to operator then it means this node is the output of a loop operator then it means we have already...