You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by eo...@apache.org on 2021/06/10 09:57:24 UTC
[pulsar] branch master updated (c75d45b -> 18f2f4a)

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 c75d45b  Introduce metrics servlet timeout setting (#10886)
     add 18f2f4a  Make KeyValueSchema an interface visible in the public Schema API (#10888)

No new revisions were added by this update.

Summary of changes:
 .../apache/pulsar/broker/service/KeyValueTest.java |  16 +--
 .../pulsar/broker/service/NullValueTest.java       |  10 +-
 .../KeyValueSchemaCompatibilityCheckTest.java      | 118 ++++++++++-----------
 .../apache/pulsar/client/api/SimpleSchemaTest.java |  16 +--
 .../java/org/apache/pulsar/schema/SchemaTest.java  |  12 +--
 .../pulsar/client/api/schema/KeyValueSchema.java   |  31 ++++--
 .../client/internal/DefaultImplementation.java     |   8 +-
 .../org/apache/pulsar/client/impl/MessageImpl.java |  12 +--
 .../client/impl/TypedMessageBuilderImpl.java       |  10 +-
 .../client/impl/schema/AutoConsumeSchema.java      |   2 +-
 .../client/impl/schema/AutoProduceBytesSchema.java |   6 +-
 ...KeyValueSchema.java => KeyValueSchemaImpl.java} |  63 ++++++++---
 .../client/impl/schema/KeyValueSchemaTest.java     |  48 ++++-----
 .../SupportVersioningKeyValueSchemaTest.java       |  12 +--
 .../impl/schema/generic/GenericSchemaImplTest.java |   6 +-
 .../impl/schema/generic/GenericSchemaTest.java     |   6 +-
 .../pulsar/functions/instance/SinkRecord.java      |   4 +-
 .../apache/pulsar/functions/sink/PulsarSink.java   |   2 +-
 .../pulsar/io/kafka/connect/KafkaConnectSink.java  |   3 +-
 .../pulsar/sql/presto/TestPulsarRecordCursor.java  |   8 +-
 .../integration/io/TestGenericObjectSink.java      |   2 +-
 .../tests/integration/io/PulsarIOTestRunner.java   |   7 +-
 .../tests/integration/presto/TestBasicPresto.java  |   8 +-
 23 files changed, 219 insertions(+), 191 deletions(-)
 copy pulsar-functions/api-java/src/main/java/org/apache/pulsar/functions/api/KVRecord.java => pulsar-client-api/src/main/java/org/apache/pulsar/client/api/schema/KeyValueSchema.java (60%)
 rename pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/{KeyValueSchema.java => KeyValueSchemaImpl.java} (85%)