This is an automated email from the ASF dual-hosted git repository.
zhaijia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from ebd70de Fix setting backlogQuota will always succeed (#9382)
add a1107ad [PIP-71][SQL]Pulsar SQL migrate SchemaHandle to presto
decoder (#8422)
No new revisions were added by this update.
Summary of changes:
pulsar-sql/presto-distribution/LICENSE | 3 +
pulsar-sql/presto-pulsar/pom.xml | 26 ++
.../pulsar/sql/presto/AvroSchemaHandler.java | 101 -----
.../pulsar/sql/presto/JSONSchemaHandler.java | 108 -----
.../pulsar/sql/presto/KeyValueSchemaHandler.java | 105 -----
.../pulsar/sql/presto/PulsarColumnHandle.java | 75 ++--
.../pulsar/sql/presto/PulsarColumnMetadata.java | 128 +++++-
.../pulsar/sql/presto/PulsarConnectorModule.java | 8 +
.../presto/PulsarDispatchingRowDecoderFactory.java | 84 ++++
.../sql/presto/PulsarFieldValueProviders.java | 47 +-
.../pulsar/sql/presto/PulsarInternalColumn.java | 173 ++------
.../apache/pulsar/sql/presto/PulsarMetadata.java | 279 ++----------
.../sql/presto/PulsarPrimitiveSchemaHandler.java | 61 ---
.../pulsar/sql/presto/PulsarRecordCursor.java | 303 +++++++------
.../apache/pulsar/sql/presto/PulsarRecordSet.java | 10 +-
.../pulsar/sql/presto/PulsarRecordSetProvider.java | 8 +-
.../apache/pulsar/sql/presto/PulsarRowDecoder.java | 23 +-
.../pulsar/sql/presto/PulsarRowDecoderFactory.java | 51 +++
.../pulsar/sql/presto/PulsarSchemaHandlers.java | 67 ---
.../pulsar/sql/presto/PulsarSplitManager.java | 2 +-
.../sql/presto/PulsarSqlSchemaInfoProvider.java | 13 +-
.../apache/pulsar/sql/presto/SchemaHandler.java | 45 --
.../decoder/avro/PulsarAvroColumnDecoder.java | 385 +++++++++++++++++
.../presto/decoder/avro/PulsarAvroRowDecoder.java | 77 ++++
.../decoder/avro/PulsarAvroRowDecoderFactory.java | 190 +++++++++
.../sql/presto/decoder/avro}/package-info.java | 5 +-
.../decoder/json/PulsarJsonFieldDecoder.java | 438 +++++++++++++++++++
.../presto/decoder/json/PulsarJsonRowDecoder.java | 89 ++++
.../decoder/json/PulsarJsonRowDecoderFactory.java | 186 ++++++++
.../sql/presto/decoder/json}/package-info.java | 5 +-
.../primitive/PulsarPrimitiveRowDecoder.java | 101 +++++
.../PulsarPrimitiveRowDecoderFactory.java | 115 +++++
.../presto/decoder/primitive}/package-info.java | 5 +-
.../pulsar/sql/presto/TestAvroSchemaHandler.java | 127 ------
.../pulsar/sql/presto/TestPulsarConnector.java | 471 +++++----------------
.../sql/presto/TestPulsarConnectorConfig.java | 2 +-
.../presto/TestPulsarKeyValueSchemaHandler.java | 353 ---------------
.../pulsar/sql/presto/TestPulsarMetadata.java | 56 +--
.../presto/TestPulsarPrimitiveSchemaHandler.java | 164 -------
.../pulsar/sql/presto/TestPulsarRecordCursor.java | 391 +++++++++++++----
.../sql/presto/decoder/AbstractDecoderTester.java | 133 ++++++
.../sql/presto/decoder/DecoderTestMessage.java | 91 ++++
.../pulsar/sql/presto/decoder/DecoderTestUtil.java | 121 ++++++
.../presto/decoder/avro/AvroDecoderTestUtil.java | 199 +++++++++
.../sql/presto/decoder/avro/TestAvroDecoder.java | 290 +++++++++++++
.../presto/decoder/json/JsonDecoderTestUtil.java | 199 +++++++++
.../sql/presto/decoder/json/TestJsonDecoder.java | 284 +++++++++++++
.../primitive/PrimitiveDecoderTestUtil.java | 36 +-
.../decoder/primitive/TestPrimitiveDecoder.java | 233 ++++++++++
49 files changed, 4194 insertions(+), 2272 deletions(-)
delete mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/AvroSchemaHandler.java
delete mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/JSONSchemaHandler.java
delete mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/KeyValueSchemaHandler.java
create mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarDispatchingRowDecoderFactory.java
copy
managed-ledger/src/main/java/org/apache/bookkeeper/mledger/util/SafeRun.java =>
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarFieldValueProviders.java
(52%)
delete mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarPrimitiveSchemaHandler.java
copy
pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/source/RecordWithEncryptionContext.java
=>
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRowDecoder.java
(65%)
create mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRowDecoderFactory.java
delete mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSchemaHandlers.java
delete mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/SchemaHandler.java
create mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroColumnDecoder.java
create mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroRowDecoder.java
create mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroRowDecoderFactory.java
copy
{pulsar-broker-common/src/main/java/org/apache/pulsar/broker/web/plugin/servlet
=>
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro}/package-info.java
(88%)
create mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonFieldDecoder.java
create mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonRowDecoder.java
create mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonRowDecoderFactory.java
copy
{pulsar-broker-common/src/main/java/org/apache/pulsar/broker/web/plugin/servlet
=>
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json}/package-info.java
(88%)
create mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/PulsarPrimitiveRowDecoder.java
create mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/PulsarPrimitiveRowDecoderFactory.java
copy
{pulsar-broker-common/src/main/java/org/apache/pulsar/broker/web/plugin/servlet
=>
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive}/package-info.java
(85%)
delete mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestAvroSchemaHandler.java
delete mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarKeyValueSchemaHandler.java
delete mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarPrimitiveSchemaHandler.java
create mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/AbstractDecoderTester.java
create mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/DecoderTestMessage.java
create mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/DecoderTestUtil.java
create mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/AvroDecoderTestUtil.java
create mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/TestAvroDecoder.java
create mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/json/JsonDecoderTestUtil.java
create mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/json/TestJsonDecoder.java
copy
pulsar-client/src/main/java/org/apache/pulsar/client/impl/BatchMessageAckerDisabled.java
=>
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/primitive/PrimitiveDecoderTestUtil.java
(54%)
create mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/primitive/TestPrimitiveDecoder.java
