This is an automated email from the ASF dual-hosted git repository.
juri pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/wayang.git
from 7337a78c1 Merge pull request #683 from mspruc/implicit-version-for-poms
add 6ca23cd1e add support ApacheIcebergSource in Wayang Basic
add 3c2f21bb7 Add support for a Basic ApacheIcebergSource
add b1d311f5d Add implementation for a JavaApacheIcergSource that allows
to read from an Apache Iceberg table
add cee5f6959 Add support for a basic ApacheIcebergSink that allows to
write data to an Iceberg Table location
add 736f4cd76 Add implementation for a JavaApacheIcebergSink that allows
to write Wayang Records to an Iceberg location for the Java Platform
add 6fd5874bc refactor whereExpression to be of type Collection and not
List
add 9597d52d5 Add mappings for iceberg source and sinks
add f720435bd Suport for Source iceberg Tables
add 3c5efc1b2 add methods to read from and write to iceberg tables
add 2e5c8859c add source operators for apache iceberg for tje Java Platform
add f552d28bd add sink operators for Apache Iceberg for the Java Platform
add 7fd48d656 Merge branch 'main' into main
add 0e67d6a32 update imports for wayang-api-scala-java files
add 813e0506d update imports so all class names are not fully qualifed
with namespace references
add a0df79daf change references to be apache iceberg source
add 8f99f1ab3 fix unamibious reference with CardinalityEstimators
add d2fc0d55a add space between tableIdentifier and Class object.
add 528f563b9 Resolve issue on it needs to be
this.whereExpressions.size() > 0
new 603df6a48 Merge pull request #656 from ChristofferEmilKristensen/main
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../scala/org/apache/wayang/api/DataQuanta.scala | 45 ++-
.../org/apache/wayang/api/DataQuantaBuilder.scala | 25 ++
.../org/apache/wayang/api/JavaPlanBuilder.scala | 20 +-
.../scala/org/apache/wayang/api/PlanBuilder.scala | 19 +-
wayang-commons/wayang-basic/pom.xml | 44 +++
.../wayang/basic/operators/ApacheIcebergSink.java | 76 +++++
.../basic/operators/ApacheIcebergSource.java | 339 +++++++++++++++++++++
...kMapping.java => ApacheIcebergSinkMapping.java} | 25 +-
...apping.java => ApacheIcebergSourceMapping.java} | 26 +-
.../org/apache/wayang/java/mapping/Mappings.java | 4 +-
.../java/operators/JavaApacheIcebergSink.java | 193 ++++++++++++
.../java/operators/JavaApacheIcebergSource.java | 163 ++++++++++
12 files changed, 954 insertions(+), 25 deletions(-)
create mode 100644
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ApacheIcebergSink.java
create mode 100644
wayang-commons/wayang-basic/src/main/java/org/apache/wayang/basic/operators/ApacheIcebergSource.java
copy
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/{ObjectFileSinkMapping.java
=> ApacheIcebergSinkMapping.java} (72%)
copy
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/mapping/{TextFileSourceMapping.java
=> ApacheIcebergSourceMapping.java} (69%)
create mode 100644
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaApacheIcebergSink.java
create mode 100644
wayang-platforms/wayang-java/src/main/java/org/apache/wayang/java/operators/JavaApacheIcebergSource.java
