You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by cr...@apache.org on 2014/04/07 20:19:25 UTC
git commit: SAMZA-79; update commetns for job config rewriter
Repository: incubator-samza
Updated Branches:
refs/heads/master 45a33f1fb -> b4a323d16
SAMZA-79; update commetns for job config rewriter
Project: http://git-wip-us.apache.org/repos/asf/incubator-samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-samza/commit/b4a323d1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-samza/tree/b4a323d1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-samza/diff/b4a323d1
Branch: refs/heads/master
Commit: b4a323d167066f42fb5a3f4baeae80dd95013f1f
Parents: 45a33f1
Author: Yan Fang <ya...@gmail.com>
Authored: Mon Apr 7 11:19:19 2014 -0700
Committer: Chris Riccomini <cr...@criccomi-mn.linkedin.biz>
Committed: Mon Apr 7 11:19:19 2014 -0700
----------------------------------------------------------------------
.../main/scala/org/apache/samza/config/JobConfig.scala | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-samza/blob/b4a323d1/samza-core/src/main/scala/org/apache/samza/config/JobConfig.scala
----------------------------------------------------------------------
diff --git a/samza-core/src/main/scala/org/apache/samza/config/JobConfig.scala b/samza-core/src/main/scala/org/apache/samza/config/JobConfig.scala
index 150ea93..fcafe83 100644
--- a/samza-core/src/main/scala/org/apache/samza/config/JobConfig.scala
+++ b/samza-core/src/main/scala/org/apache/samza/config/JobConfig.scala
@@ -22,8 +22,15 @@ package org.apache.samza.config
object JobConfig {
// job config constants
val STREAM_JOB_FACTORY_CLASS = "job.factory.class" // streaming.job_factory_class
- val CONFIG_REWRITERS = "job.config.rewriters" // CSV list of config rewriter classes to apply
- val CONFIG_REWRITER_CLASS = "job.config.rewriter.%s.class"
+
+ /**
+ * job.config.rewriters is a CSV list of config rewriter names. Each name is determined
+ * by the %s value in job.config.rewriter.%s.class. For example, if you define
+ * job.config.rewriter.some-regex.class=org.apache.samza.config.RegExTopicGenerator,
+ * then the rewriter config would be set to job.config.rewriters = some-regex.
+ */
+ val CONFIG_REWRITERS = "job.config.rewriters" // streaming.job_config_rewriters
+ val CONFIG_REWRITER_CLASS = "job.config.rewriter.%s.class" // streaming.job_config_rewriter_class - regex, system, config
val JOB_NAME = "job.name" // streaming.job_name
val JOB_ID = "job.id" // streaming.job_id