You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ni...@apache.org on 2022/06/24 13:01:11 UTC
[pulsar] branch master updated: [fix][functions] Fix UserConfigWindowFunction (#16126)
This is an automated email from the ASF dual-hosted git repository.
nicoloboschi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 364a4fc3bed [fix][functions] Fix UserConfigWindowFunction (#16126)
364a4fc3bed is described below
commit 364a4fc3bedcf5d1ba77a21c4f29706cc3dfef1e
Author: Christophe Bornet <cb...@hotmail.com>
AuthorDate: Fri Jun 24 15:01:03 2022 +0200
[fix][functions] Fix UserConfigWindowFunction (#16126)
---
.../functions/api/examples/window/UserConfigWindowFunction.java | 8 +-------
1 file changed, 1 insertion(+), 7 deletions(-)
diff --git a/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/window/UserConfigWindowFunction.java b/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/window/UserConfigWindowFunction.java
index da524a3b6e2..98bf08f59f8 100644
--- a/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/window/UserConfigWindowFunction.java
+++ b/pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/window/UserConfigWindowFunction.java
@@ -19,7 +19,6 @@
package org.apache.pulsar.functions.api.examples.window;
import java.util.Collection;
-import java.util.Optional;
import org.apache.pulsar.functions.api.Record;
import org.apache.pulsar.functions.api.WindowContext;
import org.apache.pulsar.functions.api.WindowFunction;
@@ -30,11 +29,6 @@ import org.apache.pulsar.functions.api.WindowFunction;
public class UserConfigWindowFunction implements WindowFunction<String, String> {
@Override
public String process(Collection<Record<String>> input, WindowContext context) throws Exception {
- Optional<Object> whatToWrite = context.getUserConfigValue("WhatToWrite");
- if (whatToWrite.get() != null) {
- return (String) whatToWrite.get();
- } else {
- return "Not a nice way";
- }
+ return (String) context.getUserConfigValue("WhatToWrite").orElse("Not a nice way");
}
}