ConcurrencyPractitioner commented on a change in pull request #4127:
[Issue#4110] [component/functions] Adding getActualMessage() method
URL: https://github.com/apache/pulsar/pull/4127#discussion_r279142379
##########
File path:
pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/Context.java
##########
@@ -33,6 +33,12 @@
* executing function
*/
public interface Context {
+
+ /**
+ * Access the message associated with current input value.
+ */
+ Object getCurrentMessage();
Review comment:
Oh, yeah. I was stupid for not understanding what was required. Sorry about
that. I took a look at PulsarFunctions examples and it helped. Added a use case
in examples.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
