Moved api/examples to api-java and java-examples (#128)

pulsar-functions/pom.xml

@@ -33,11 +33,11 @@
 
   <modules>
     <module>proto</module>
-    <module>api</module>
+    <module>api-java</module>
     <module>runtime</module>
     <module>worker</module>
     <module>cli</module>
-    <module>api-examples</module>
+    <module>java-examples</module>
     <module>runtime-benchmark</module>
   </modules>
 

pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/container/ProcessFunctionContainer.java

@@ -124,7 +124,7 @@ class ProcessFunctionContainer implements FunctionContainer {
         args.add(pulsarServiceUrl);
         args.add("--max-buffered-tuples");
         args.add(String.valueOf(maxBufferedTuples));
-        Map<String, String> userConfig = instanceConfig.getFunctionConfig().getUserConfig();
+        Map<String, String> userConfig = instanceConfig.getFunctionConfig().getUserConfigMap();
         String userConfigString = "";
         if (userConfig != null && !userConfig.isEmpty()) {
             for (Map.Entry<String, String> entry : userConfig.entrySet()) {

pulsar-functions/runtime/src/main/java/org/apache/pulsar/functions/runtime/instance/ContextImpl.java

@@ -157,8 +157,8 @@ class ContextImpl implements Context {
 
     @Override
     public String getUserConfigValue(String key) {
-        if (config.getFunctionConfig().getUserConfig().containsKey(key)) {
-            return config.getFunctionConfig().getUserConfig().get(key);
+        if (config.getFunctionConfig().containsUserConfig(key)) {
+            return config.getFunctionConfig().getUserConfigOrDefault(key, null);
         } else {
             return null;
         }