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 2015/03/12 21:35:17 UTC
samza git commit: SAMZA-550; remove dead code from serializer config
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 <be...@gmail.com>
Authored: Thu Mar 12 13:35:05 2015 -0700
Committer: Chris Riccomini <cr...@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", ""))
}
}