You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by ca...@apache.org on 2020/02/12 18:10:17 UTC
[samza] branch master updated (ea49010 -> f1a8b51)
This is an automated email from the ASF dual-hosted git repository.
cameronlee pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/samza.git.
from ea49010 SAMZA-2455: Validate the argument types in SamzaSQL UDF on execution planning phase (#1269)
add f1a8b51 SAMZA-2448: [Scala cleanup] Clean up and convert some parts of samza-kafka to java (#1263)
No new revisions were added by this update.
Summary of changes:
.../samza/config/TestRegExTopicGenerator.scala | 5 +-
.../samza/system/kafka/KafkaConsumerProxy.java | 0
.../system/kafka/KafkaConsumerProxyFactory.java | 0
.../main/java/org/apache/samza/util/KafkaUtil.java | 60 +++++++++++
.../scala/org/apache/samza/system/kafka/Toss.scala | 28 ------
.../scala/org/apache/samza/util/KafkaUtil.scala | 111 ---------------------
.../org/apache/samza/util/KafkaUtilException.scala | 31 ------
.../java/org/apache/samza/util/TestKafkaUtil.java | 106 ++++++++++++++++++++
.../kafka/TestKafkaCheckpointManager.scala | 32 +++---
.../org/apache/samza/utils/TestKafkaUtil.scala | 33 ------
10 files changed, 186 insertions(+), 220 deletions(-)
rename {samza-kafka => samza-core}/src/test/scala/org/apache/samza/config/TestRegExTopicGenerator.scala (97%)
rename samza-kafka/src/main/{scala => java}/org/apache/samza/system/kafka/KafkaConsumerProxy.java (100%)
rename samza-kafka/src/main/{scala => java}/org/apache/samza/system/kafka/KafkaConsumerProxyFactory.java (100%)
create mode 100644 samza-kafka/src/main/java/org/apache/samza/util/KafkaUtil.java
delete mode 100644 samza-kafka/src/main/scala/org/apache/samza/system/kafka/Toss.scala
delete mode 100644 samza-kafka/src/main/scala/org/apache/samza/util/KafkaUtil.scala
delete mode 100644 samza-kafka/src/main/scala/org/apache/samza/util/KafkaUtilException.scala
create mode 100644 samza-kafka/src/test/java/org/apache/samza/util/TestKafkaUtil.java
delete mode 100644 samza-kafka/src/test/scala/org/apache/samza/utils/TestKafkaUtil.scala