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 <[email protected]> Authored: Mon Apr 7 11:19:19 2014 -0700 Committer: Chris Riccomini <[email protected]> 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
