This is an automated email from the ASF dual-hosted git repository. zkaoudi pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/wayang.git
commit 92cff9212daf541bacfd3f2d2a538bccb2775808 Merge: de5009554 2d453ed8a Author: Zoi Kaoudi <[email protected]> AuthorDate: Thu Mar 12 09:41:06 2026 +0100 Merge pull request #665 from harrygav/introduce_postgresql_sink Add TableSink operator with Java/Spark implementations .../apache/wayang/basic/operators/TableSink.java | 101 +++++++ .../apache/wayang/basic/util/DatabaseProduct.java | 34 +++ .../org/apache/wayang/basic/util/SqlTypeUtils.java | 197 +++++++++++++ .../apache/wayang/basic/util/SqlTypeUtilsTest.java | 145 +++++++++ wayang-platforms/wayang-java/pom.xml | 6 + .../wayang/java/operators/JavaTableSink.java | 266 +++++++++++++++++ .../wayang/java/operators/JavaTableSinkTest.java | 328 +++++++++++++++++++++ .../java/operators/JavaTextFileSourceTest.java | 7 +- wayang-platforms/wayang-spark/pom.xml | 6 + .../wayang/spark/operators/SparkTableSink.java | 198 +++++++++++++ .../wayang/spark/operators/SparkTableSinkTest.java | 262 ++++++++++++++++ 11 files changed, 1547 insertions(+), 3 deletions(-) diff --cc wayang-platforms/wayang-java/pom.xml index d45e58fe7,48ef59a84..9cd901d26 --- a/wayang-platforms/wayang-java/pom.xml +++ b/wayang-platforms/wayang-java/pom.xml @@@ -69,7 -73,18 +69,13 @@@ <artifactId>slf4j-api</artifactId> <version>2.0.6</version> </dependency> - <dependency> - <groupId>org.apache.logging.log4j</groupId> - <artifactId>log4j-slf4j-impl</artifactId> - <version>2.20.0</version> - </dependency> <!-- Mockito for mocking --> + <dependency> + <groupId>com.h2database</groupId> + <artifactId>h2</artifactId> + <version>2.2.224</version> + <scope>test</scope> + </dependency> <dependency> <groupId>org.mockito</groupId> <artifactId>mockito-core</artifactId>
