Repository: samza Updated Branches: refs/heads/master c725b3ceb -> 13ee70622
SAMZA-550; remove dead code from serializer config Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/13ee7062 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/13ee7062 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/13ee7062 Branch: refs/heads/master Commit: 13ee706225678172675163f088f499f78474ce43 Parents: c725b3c Author: Benjamin Fradet <benjamin.fra...@gmail.com> Authored: Thu Mar 12 13:35:05 2015 -0700 Committer: Chris Riccomini <criccom...@apache.org> Committed: Thu Mar 12 13:35:05 2015 -0700 ---------------------------------------------------------------------- .../src/main/scala/org/apache/samza/config/SerializerConfig.scala | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/13ee7062/samza-core/src/main/scala/org/apache/samza/config/SerializerConfig.scala ---------------------------------------------------------------------- diff --git a/samza-core/src/main/scala/org/apache/samza/config/SerializerConfig.scala b/samza-core/src/main/scala/org/apache/samza/config/SerializerConfig.scala index 0c026e6..8e3eb57 100644 --- a/samza-core/src/main/scala/org/apache/samza/config/SerializerConfig.scala +++ b/samza-core/src/main/scala/org/apache/samza/config/SerializerConfig.scala @@ -35,8 +35,9 @@ class SerializerConfig(config: Config) extends ScalaMapConfig(config) { * Returns a list of all serializer names from the config file. Useful for * getting individual serializers. */ + import SerializerConfig._ def getSerdeNames() = { - val subConf = config.subset("serializers.registry.", true) + val subConf = config.subset(SERIALIZER_PREFIX format "", true) subConf.keys.filter(k => k.endsWith(".class")).map(_.replace(".class", "")) } }
