fix cherry-pick issue

datastax · Mar 1, 2022 · 0b7f7b3 · 0b7f7b3
1 parent d13ef6d
commit 0b7f7b3
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/BaseContext.java b/pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/BaseContext.java
@@ -19,6 +19,7 @@
 package org.apache.pulsar.functions.api;
 
 import org.apache.pulsar.client.api.ClientBuilder;
+import org.apache.pulsar.client.api.PulsarClient;
 import org.apache.pulsar.common.classification.InterfaceAudience;
 import org.apache.pulsar.common.classification.InterfaceStability;
 import org.slf4j.Logger;
@@ -193,6 +194,18 @@ default <S extends StateStore> S getStateStore(String tenant, String ns, String
      */
     void recordMetric(String metricName, double value);
 
+    /**
+     * Get the pre-configured pulsar client.
+     *
+     * You can use this client to access Pulsar cluster.
+     * The Function will be responsible for disposing this client.
+     *
+     * @return the instance of pulsar client
+     */
+    default PulsarClient getPulsarClient() {
+        throw new UnsupportedOperationException("not implemented");
+    }
+
     /**
      * Get the pre-configured pulsar client builder.
      *