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

Posted to commits@pulsar.apache.org by pe...@apache.org on 2021/08/20 09:40:07 UTC

[pulsar] branch master updated (f893c08 -> 12f6566)

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

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


    from f893c08  [Functions]Support protobuf schema for pulsar function (#11709)
     add 12f6566  [IO] Pass client builder to debezium database history (#11293)

No new revisions were added by this update.

Summary of changes:
 .../apache/pulsar/client/api/ClientBuilder.java    |  3 +-
 .../apache/pulsar/functions/api/BaseContext.java   | 19 +++++-
 .../pulsar/functions/instance/ContextImpl.java     | 10 ++-
 .../pulsar/functions/instance/InstanceUtils.java   | 28 +++++----
 .../functions/instance/JavaInstanceRunnable.java   | 13 ++--
 .../pulsar/functions/instance/ContextImplTest.java | 26 +++++---
 .../instance/JavaInstanceRunnableTest.java         | 12 +++-
 .../functions/runtime/thread/ThreadRuntime.java    |  9 ++-
 .../runtime/thread/ThreadRuntimeFactory.java       |  5 +-
 .../worker/FunctionRuntimeManagerTest.java         | 26 ++++----
 .../worker/rest/api/FunctionsImplTest.java         |  7 ++-
 pulsar-io/debezium/core/pom.xml                    | 12 ++--
 .../apache/pulsar/io/debezium/DebeziumSource.java  |  4 ++
 .../pulsar/io/debezium/PulsarDatabaseHistory.java  | 48 ++++++++++-----
 .../org/apache/pulsar/io/debezium/SerDeUtils.java  | 71 ++++++++++++++++++++++
 .../io/debezium/PulsarDatabaseHistoryTest.java     | 47 +++++++++-----
 16 files changed, 255 insertions(+), 85 deletions(-)
 create mode 100644 pulsar-io/debezium/core/src/main/java/org/apache/pulsar/io/debezium/SerDeUtils.java