This is an automated email from the ASF dual-hosted git repository.
eolivelli pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 8f3a564 Converted bundle split into an HTTP async operation (#10619)
add 8183a1e SinkContext: ability to seek/pause/resume consumer for a
topic (#10498)
No new revisions were added by this update.
Summary of changes:
.../pulsar/functions/instance/ContextImpl.java | 86 +++++++++-
.../functions/instance/JavaInstanceRunnable.java | 4 +
.../source/MultiConsumerPulsarSource.java | 7 +-
.../pulsar/functions/source/PulsarSource.java | 4 +
.../source/SingleConsumerPulsarSource.java | 9 ++
.../pulsar/functions/instance/ContextImplTest.java | 180 ++++++++++++++++++---
.../pulsar/functions/source/PulsarSourceTest.java | 25 +++
.../org/apache/pulsar/io/core/SinkContext.java | 31 ++++
8 files changed, 321 insertions(+), 25 deletions(-)
