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/incubator-wayang.git
commit f05a09fc04cded0ab182c2b8277d93da18328b69 Merge: d4fa09229 fd6b50663 Author: Zoi Kaoudi <[email protected]> AuthorDate: Wed Dec 10 21:07:31 2025 +0100 Merge pull request #639 from zkaoudi/main Added/corrected annotations of operators .../java/org/apache/wayang/flink/operators/FlinkLoopOperator.java | 2 +- .../org/apache/wayang/flink/operators/FlinkTextFileSource.java | 2 +- .../java/org/apache/wayang/flink/operators/FlinkTsvFileSink.java | 3 ++- .../org/apache/wayang/flink/operators/FlinkZipWithIdOperator.java | 2 +- .../java/org/apache/wayang/java/operators/JavaAmazonS3Source.java | 7 ++++++- .../apache/wayang/java/operators/JavaAzureBlobStorageSource.java | 6 +++++- .../org/apache/wayang/java/operators/JavaCollectionSource.java | 2 +- .../wayang/java/operators/JavaGoogleCloudStorageSource.java | 8 ++++++++ .../java/org/apache/wayang/java/operators/JavaKafkaTopicSink.java | 2 ++ .../org/apache/wayang/java/operators/JavaKafkaTopicSource.java | 7 +++++++ .../java/org/apache/wayang/java/operators/JavaParquetSource.java | 2 +- .../java/org/apache/wayang/java/operators/JavaRepeatOperator.java | 2 +- .../java/org/apache/wayang/java/operators/JavaTextFileSink.java | 2 ++ .../java/org/apache/wayang/java/operators/JavaTextFileSource.java | 4 +++- .../java/org/apache/wayang/java/operators/JavaTsvFileSink.java | 2 +- .../java/org/apache/wayang/java/operators/JavaTsvFileSource.java | 4 ++-- .../org/apache/wayang/spark/operators/SparkCoGroupOperator.java | 2 +- .../org/apache/wayang/spark/operators/SparkCollectOperator.java | 2 +- .../org/apache/wayang/spark/operators/SparkIntersectOperator.java | 2 +- .../org/apache/wayang/spark/operators/SparkKafkaTopicSink.java | 2 ++ .../org/apache/wayang/spark/operators/SparkKafkaTopicSource.java | 7 +++---- .../org/apache/wayang/spark/operators/SparkParquetSource.java | 2 +- .../java/org/apache/wayang/spark/operators/SparkTextFileSink.java | 2 ++ .../org/apache/wayang/spark/operators/SparkTextFileSource.java | 4 +++- .../java/org/apache/wayang/spark/operators/SparkTsvFileSink.java | 2 +- .../org/apache/wayang/spark/operators/SparkTsvFileSource.java | 4 ++-- .../org/apache/wayang/spark/operators/SparkZipWithIdOperator.java | 2 +- .../wayang/tensorflow/operators/TensorflowDLTrainingOperator.java | 6 ++++++ .../wayang/tensorflow/operators/TensorflowPredictOperator.java | 6 ++++++ 29 files changed, 74 insertions(+), 26 deletions(-)
