You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by zh...@apache.org on 2020/05/08 03:05:35 UTC

[pulsar] branch master updated (b9e9609 -> 7cd28b9)

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

zhaijia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.


    from b9e9609  Add note for bookkeeper explicit LAC (#6908)
     add 7cd28b9  Support function with format: Function<I, CompletableFuture<O>> (#6684)

No new revisions were added by this update.

Summary of changes:
 .../pulsar/common/functions/FunctionConfig.java    |  3 +
 .../pulsar/functions/instance/InstanceConfig.java  |  3 +
 .../pulsar/functions/instance/JavaInstance.java    | 64 +++++++++++++--
 .../functions/instance/JavaInstanceRunnable.java   | 41 ++++-----
 .../functions/instance/JavaInstanceTest.java       | 96 ++++++++++++++++++++--
 .../api/examples/AsyncContextFunction.java         | 59 +++++++++++++
 ...ava => JavaNativeAsyncExclamationFunction.java} | 26 +++---
 .../org/apache/pulsar/functions/LocalRunner.java   |  2 +
 .../functions/runtime/JavaInstanceStarter.java     |  4 +
 .../pulsar/functions/worker/WorkerConfig.java      |  6 ++
 .../pulsar/functions/worker/FunctionActioner.java  |  1 +
 11 files changed, 264 insertions(+), 41 deletions(-)
 create mode 100644 pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/AsyncContextFunction.java
 copy pulsar-functions/java-examples/src/main/java/org/apache/pulsar/functions/api/examples/{AddWindowFunction.java => JavaNativeAsyncExclamationFunction.java} (59%)