[incubator-pulsar] branch master updated: Fix var names of context that were changed (#1676)

[sijie]

This is an automated email from the ASF dual-hosted git repository.

sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 8dbee11  Fix var names of context that were changed (#1676)
8dbee11 is described below

commit 8dbee119232d58cf5fb617f5dfeaea5fcf44aa09
Author: Sanjeev Kulkarni <sanjee...@gmail.com>
AuthorDate: Fri Apr 27 16:20:25 2018 -0700

    Fix var names of context that were changed (#1676)
---
 pulsar-functions/instance/src/main/python/contextimpl.py | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/pulsar-functions/instance/src/main/python/contextimpl.py 
b/pulsar-functions/instance/src/main/python/contextimpl.py
index f950abf..6e59306 100644
--- a/pulsar-functions/instance/src/main/python/contextimpl.py
+++ b/pulsar-functions/instance/src/main/python/contextimpl.py
@@ -73,7 +73,7 @@ class ContextImpl(pulsar.Context):
     return self.current_topic_name
 
   def get_function_name(self):
-    return self.instance_config.function_config.name
+    return self.instance_config.function_details.name
 
   def get_function_id(self):
     return self.instance_config.function_id
@@ -88,13 +88,13 @@ class ContextImpl(pulsar.Context):
     return self.log
 
   def get_user_config_value(self, key):
-    if key in self.instance_config.function_config.userConfig:
-      return str(self.instance_config.function_config.userConfig[key])
+    if key in self.instance_config.function_details.userConfig:
+      return str(self.instance_config.function_details.userConfig[key])
     else:
       return None
   
   def get_user_config_map(self):
-    return self.instance_config.function_config.userConfig
+    return self.instance_config.function_details.userConfig
 
   def record_metric(self, metric_name, metric_value):
     if not metric_name in self.accumulated_metrics:
@@ -102,10 +102,10 @@ class ContextImpl(pulsar.Context):
     self.accumulated_metrics[metric_name].update(metric_value)
 
   def get_output_topic(self):
-    return self.instance_config.function_config.output
+    return self.instance_config.function_details.output
 
   def get_output_serde_class_name(self):
-    return self.instance_config.function_config.outputSerdeClassName
+    return self.instance_config.function_details.outputSerdeClassName
 
   def publish(self, topic_name, message):
     return self.publish(topic_name, message, "serde.IdentitySerDe")

-- 
To stop receiving notification emails like this one, please contact
si...@apache.org.