You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by na...@apache.org on 2016/03/18 00:55:33 UTC
samza git commit: SAMZA-897: TaskConfig uses getOrDefault() which is
not available in Java 7
Repository: samza
Updated Branches:
refs/heads/master 85ecf0a2c -> 964f56e75
SAMZA-897: TaskConfig uses getOrDefault() which is not available in Java 7
Project: http://git-wip-us.apache.org/repos/asf/samza/repo
Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/964f56e7
Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/964f56e7
Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/964f56e7
Branch: refs/heads/master
Commit: 964f56e752e0860012dbee4634e21743ef50684c
Parents: 85ecf0a
Author: Jacob Maes <ja...@gmail.com>
Authored: Thu Mar 17 14:52:08 2016 -0700
Committer: Navina Ramesh <nr...@linkedin.com>
Committed: Thu Mar 17 16:55:16 2016 -0700
----------------------------------------------------------------------
samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/samza/blob/964f56e7/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala
----------------------------------------------------------------------
diff --git a/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala b/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala
index 6ff9aac..08a4deb 100644
--- a/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala
+++ b/samza-core/src/main/scala/org/apache/samza/config/TaskConfig.scala
@@ -94,7 +94,7 @@ class TaskConfig(config: Config) extends ScalaMapConfig(config) with Logging {
def getCommandClass = getOption(TaskConfig.COMMAND_BUILDER)
- def getCommandClass(defaultValue: String) = getOrDefault(TaskConfig.COMMAND_BUILDER, defaultValue)
+ def getCommandClass(defaultValue: String) = getOrElse(TaskConfig.COMMAND_BUILDER, defaultValue)
def getCheckpointManagerFactory() = getOption(TaskConfig.CHECKPOINT_MANAGER_FACTORY)