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%)
