This is an automated email from the ASF dual-hosted git repository. glauesppen pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/incubator-wayang.git
commit fb60597f4e86037e440cca5eb0ec135ddd83f6ac Author: AdityaGoel11 <[email protected]> AuthorDate: Mon Oct 9 21:58:54 2023 +0530 Address @kbeedkar's feedback --- .../src/test/java/org/apache/wayang/api/sql/SqlTest.java | 9 ++++----- wayang-api/wayang-api-sql/src/test/resources/model.json | 8 ++++++++ 2 files changed, 12 insertions(+), 5 deletions(-) diff --git a/wayang-api/wayang-api-sql/src/test/java/org/apache/wayang/api/sql/SqlTest.java b/wayang-api/wayang-api-sql/src/test/java/org/apache/wayang/api/sql/SqlTest.java index c1d25869..58dd71df 100755 --- a/wayang-api/wayang-api-sql/src/test/java/org/apache/wayang/api/sql/SqlTest.java +++ b/wayang-api/wayang-api-sql/src/test/java/org/apache/wayang/api/sql/SqlTest.java @@ -39,9 +39,9 @@ public class SqlTest { public static void main(String[] args) { WayangPlan wayangPlan; Configuration configuration = new Configuration(); - configuration.setProperty("wayang.postgres.jdbc.url", "jdbc:postgresql://localhost:5432/dvdrental"); - configuration.setProperty("wayang.postgres.jdbc.user", "aditya"); - configuration.setProperty("wayang.postgres.jdbc.password", "12345678"); + configuration.setProperty("wayang.postgres.jdbc.url", "jdbc:postgresql://localhost:5432/imdb"); + configuration.setProperty("wayang.postgres.jdbc.user", "postgres"); + configuration.setProperty("wayang.postgres.jdbc.password", "password"); WayangContext wayangContext = new WayangContext(configuration) .withPlugin(Java.basicPlugin()) @@ -50,7 +50,7 @@ public class SqlTest { Collection<Record> collector = new ArrayList<>(); - TableSource customer = new PostgresTableSource("sales"); + TableSource customer = new PostgresTableSource("person"); MapOperator<Record, Record> projection = MapOperator.createProjection( Record.class, Record.class, @@ -93,4 +93,3 @@ public class SqlTest { } - diff --git a/wayang-api/wayang-api-sql/src/test/resources/model.json b/wayang-api/wayang-api-sql/src/test/resources/model.json index 0a5ea233..051898cb 100644 --- a/wayang-api/wayang-api-sql/src/test/resources/model.json +++ b/wayang-api/wayang-api-sql/src/test/resources/model.json @@ -12,6 +12,14 @@ "jdbcUser": "aditya", "jdbcPassword": "12345678" } + }, + { + "name": 'fs', + "type": 'custom', + "factory": 'org.apache.calcite.adapter.file.FileSchemaFactory', + "operand": { + "directory": 'C:/incubator-Wayang-CrossPlatform/incubator-wayang-SQL/wayang-api/wayang-api-sql/src/test/resources' + } } ] }
