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 306cf99 Fix NPE in ClientCnx (#9761)
add 86daf60 Issue-9402: [functions] Added ImmediateTrigger class and unit
tests (#9727)
No new revisions were added by this update.
Summary of changes:
pulsar-broker/pom.xml | 16 ++
.../apache/pulsar/io/PulsarFunctionE2ETest.java | 202 ++++++++++++++++++++-
.../io/batchdiscovery/ImmediateTriggerer.java} | 45 +++--
pulsar-io/pom.xml | 1 +
4 files changed, 238 insertions(+), 26 deletions(-)
copy
pulsar-io/{data-generator/src/main/java/org/apache/pulsar/io/datagenerator/DataGeneratorPrintSink.java
=>
batch-discovery-triggerers/src/main/java/org/apache/pulsar/io/batchdiscovery/ImmediateTriggerer.java}
(60%)
