incubator-wayang
incubator-wayang copied to clipboard
apache
Apache Wayang(incubating) is the first cross-platform data processing system.
enable logging than the specified value. https://github.com/apache/incubator-wayang/blob/d46f3c3f0fb963c2ee2640f00a106042fba55431/wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/CsvRowConverter.java#L146 ```java /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed...
![github-actions[bot] avatar](https://avatars.githubusercontent.com/in/15368?v=4 "github-actions[bot] avatar"){kind=avatar}
ExecutionPlan.toJsonList add documentation labels:documentation,todo @return https://github.com/apache/incubator-wayang/blob/fe066b31d72e8789886aa1217f2516c576195a32/wayang-commons/wayang-core/src/main/java/org/apache/wayang/core/plan/executionplan/ExecutionPlan.java#L99 ```java return sb.toString(); } /** * TODO: ExecutionPlan.toJsonList add documentation * labels:documentation,todo * * @return */ public List toJsonList() { Counter stageActivationCounter = new...
support other sources https://github.com/apache/incubator-wayang/blob/388cce9f8955c4c2e8df7b4094e4a7416340754f/wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/converter/WayangTableScanVisitor.java#L29 ```java package org.apache.wayang.api.sql.calcite.converter; import org.apache.wayang.api.sql.calcite.rel.WayangTableScan; import org.apache.wayang.core.plan.wayangplan.Operator; import org.apache.wayang.postgres.operators.PostgresTableSource; import java.util.List; //TODO: create tablesource with column types //TODO: support other sources public class WayangTableScanVisitor extends WayangRelNodeVisitor...
incorporate fields later for projectable table scans private final ImmutableIntList fields; https://github.com/apache/incubator-wayang/blob/d46f3c3f0fb963c2ee2640f00a106042fba55431/wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/JavaCSVTableSource.java#L56 ```java /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements....
handle different variants https://github.com/apache/incubator-wayang/blob/d46f3c3f0fb963c2ee2640f00a106042fba55431/wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/sources/fs/CsvRowConverter.java#L35 ```java /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this...
Automatically create calcite schema based on user provided configurations of table sources https://github.com/apache/incubator-wayang/blob/d46f3c3f0fb963c2ee2640f00a106042fba55431/wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/schema/SchemaUtils.java#L32 ```java /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license...
a cleaner way to handle this https://github.com/apache/incubator-wayang/blob/d46f3c3f0fb963c2ee2640f00a106042fba55431/wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java#L134 ```java /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed...
split into multiple classes https://github.com/apache/incubator-wayang/blob/d46f3c3f0fb963c2ee2640f00a106042fba55431/wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/rules/WayangRules.java#L41 ```java /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with *...
create a basic ruleset https://github.com/apache/incubator-wayang/blob/d46f3c3f0fb963c2ee2640f00a106042fba55431/wayang-api/wayang-api-sql/src/main/java/org/apache/wayang/api/sql/calcite/optimizer/Optimizer.java#L199 ```java /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with *...