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/04/08 01:15:25 UTC

[pulsar] branch master updated (ca13247 -> a2d39c0)

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 ca13247  [Doc] Add monitoring guidelines for function and connector (#10133)
     add a2d39c0  Implement GenericObject - Allow GenericRecord to wrap any Java Object (#10057)

No new revisions were added by this update.

Summary of changes:
 .../client/api/SimpleProducerConsumerTest.java     |   6 +-
 .../java/org/apache/pulsar/schema/SchemaTest.java  | 102 ++++++++++++++++++++-
 .../java/org/apache/pulsar/client/api/Schema.java  |   6 +-
 .../pulsar/client/api/schema/GenericObject.java    |  34 ++++---
 .../pulsar/client/api/schema/GenericRecord.java    |   6 +-
 .../client/impl/schema/AutoConsumeSchema.java      |  96 ++++++++++---------
 .../client/impl/schema/GenericObjectWrapper.java   |  98 ++++++++++++++++++++
 .../impl/schema/generic/GenericAvroRecord.java     |   2 +-
 .../impl/schema/generic/GenericJsonRecord.java     |   2 +-
 .../generic/GenericProtobufNativeRecord.java       |   2 +-
 .../impl/schema/generic/GenericAvroRecordTest.java |   2 +-
 .../impl/schema/generic/GenericJsonRecordTest.java |   2 +-
 .../generic/GenericProtobufNativeReaderTest.java   |   2 +-
 .../PulsarPrimitiveRowDecoderFactory.java          |   3 +-
 14 files changed, 290 insertions(+), 73 deletions(-)
 copy pulsar-common/src/main/java/org/apache/pulsar/common/naming/ServiceUnitId.java => pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/GenericObject.java (51%)
 create mode 100644 pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/GenericObjectWrapper.java