You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by je...@apache.org on 2021/04/22 17:48:21 UTC
[pulsar] branch master updated (b4adf91 -> 3f8864a)

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

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


    from b4adf91  Add Vivy to the "Powered by" Page (#10314)
     add 3f8864a  Optimize code path for functions that only read from one topic (#10315)

No new revisions were added by this update.

Summary of changes:
 .../apache/pulsar/io/PulsarFunctionE2ETest.java    | 136 ++++++++++-
 .../functions/instance/JavaInstanceRunnable.java   |  51 +++--
 .../source/MultiConsumerPulsarSource.java          | 115 ++++++++++
 ...g.java => MultiConsumerPulsarSourceConfig.java} |  30 +--
 .../pulsar/functions/source/PulsarSource.java      | 248 ++++++++-------------
 .../functions/source/PulsarSourceConfig.java       |  10 +-
 .../source/PulsarSourceConsumerConfig.java         |  30 +--
 .../pulsar/functions/source/PushPulsarSource.java  |  33 +--
 .../source/SingleConsumerPulsarSource.java         |  93 ++++++++
 .../source/SingleConsumerPulsarSourceConfig.java   |  29 ++-
 .../src/main/resources/findbugsExclude.xml         |   8 +
 .../pulsar/functions/source/PulsarSourceTest.java  | 207 ++++++++++-------
 .../io/hbase/sink/HbaseGenericRecordSinkTest.java  |   2 +-
 13 files changed, 641 insertions(+), 351 deletions(-)
 create mode 100644 pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/MultiConsumerPulsarSource.java
 copy pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/{PulsarSourceConfig.java => MultiConsumerPulsarSourceConfig.java} (61%)
 copy pulsar-common/src/main/java/org/apache/pulsar/common/functions/CryptoConfig.java => pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PulsarSourceConsumerConfig.java (64%)
 copy pulsar-io/core/src/main/java/org/apache/pulsar/io/core/PushSource.java => pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/PushPulsarSource.java (70%)
 create mode 100644 pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/SingleConsumerPulsarSource.java
 copy pulsar-client-admin/src/main/java/org/apache/pulsar/client/admin/internal/JacksonConfigurator.java => pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/SingleConsumerPulsarSourceConfig.java (60%)