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 48b3c8e Samza-2331: Fix java doc of table descriptor for default rate
limiter (#1168)
add 0effeb6 SAMZA-2326 : Add interface to support specific configs (#1165)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/samza/config/JobConfig.java | 12 ++++
.../samza/util/CoordinatorStreamConfigFactory.java | 29 +++------
.../apache/samza/util/CoordinatorStreamUtil.scala | 17 ++----
.../DefaultCoordinatorStreamConfigFactory.java | 50 ++++++++++++++++
.../org/apache/samza/config/TestJobConfig.java | 9 +++
.../TestDefaultCoordinatorStreamConfigFactory.java | 69 ++++++++++++++++++++++
.../samza/util/TestCoordinatorStreamUtil.scala | 16 +++++
7 files changed, 170 insertions(+), 32 deletions(-)
copy samza-api/src/main/java/org/apache/samza/context/JobContext.java =>
samza-core/src/main/scala/org/apache/samza/util/CoordinatorStreamConfigFactory.java
(66%)
create mode 100644
samza-core/src/main/scala/org/apache/samza/util/DefaultCoordinatorStreamConfigFactory.java
create mode 100644
samza-core/src/test/java/org/apache/samza/util/TestDefaultCoordinatorStreamConfigFactory.java
