This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 0f23dda [Build] Skip python 3.9 for master branch (#9891)
add eb972a6 [Pulsar SQL]support protobuf_native decoder (#9841)
No new revisions were added by this update.
Summary of changes:
.../presto/PulsarDispatchingRowDecoderFactory.java | 3 +
.../PulsarProtobufNativeColumnDecoder.java} | 94 +-
.../PulsarProtobufNativeRowDecoder.java} | 44 +-
.../PulsarProtobufNativeRowDecoderFactory.java | 165 +
.../{avro => protobufnative}/package-info.java | 2 +-
.../ProtobufNativeDecoderTestUtil.java} | 94 +-
.../sql/presto/decoder/protobufnative/TestMsg.java | 3935 ++++++++++++++++++++
.../presto/decoder/protobufnative/TestMsg.proto | 33 +-
.../protobufnative/TestProtobufNativeDecoder.java | 267 ++
.../pulsar/tests/integration/presto/StockMsg.proto | 13 +-
.../integration/presto/StockProtoMessage.java | 729 ++++
.../tests/integration/presto/TestBasicPresto.java | 23 +
12 files changed, 5272 insertions(+), 130 deletions(-)
copy
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/{avro/PulsarAvroColumnDecoder.java
=> protobufnative/PulsarProtobufNativeColumnDecoder.java} (82%)
copy
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/{avro/PulsarAvroRowDecoder.java
=> protobufnative/PulsarProtobufNativeRowDecoder.java} (55%)
create mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeRowDecoderFactory.java
copy
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/{avro
=> protobufnative}/package-info.java (93%)
copy
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/{avro/AvroDecoderTestUtil.java
=> protobufnative/ProtobufNativeDecoderTestUtil.java} (74%)
create mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestMsg.java
copy pulsar-client/src/test/proto/Test.proto =>
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestMsg.proto
(59%)
create mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestProtobufNativeDecoder.java
copy pulsar-client/src/test/proto/ExternalTest.proto =>
tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/StockMsg.proto
(78%)
create mode 100644
tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/StockProtoMessage.java
