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 df15210 Enable get precise backlog and backlog without delayed
messages. (#6310)
add 3cf6be1 KeyValue schema support for pulsar sql (#6325)
No new revisions were added by this update.
Summary of changes:
.../apache/pulsar/common/api/raw/RawMessage.java | 15 +
.../pulsar/common/api/raw/RawMessageImpl.java | 24 +-
.../pulsar/sql/presto/AvroSchemaHandler.java | 5 +
.../pulsar/sql/presto/JSONSchemaHandler.java | 5 +
.../pulsar/sql/presto/KeyValueSchemaHandler.java | 91 ++++++
.../pulsar/sql/presto/PulsarColumnHandle.java | 51 +++-
.../pulsar/sql/presto/PulsarColumnMetadata.java | 33 +-
.../pulsar/sql/presto/PulsarInternalColumn.java | 5 +-
.../apache/pulsar/sql/presto/PulsarMetadata.java | 86 ++++--
.../sql/presto/PulsarPrimitiveSchemaHandler.java | 5 +
.../pulsar/sql/presto/PulsarRecordCursor.java | 11 +-
.../pulsar/sql/presto/PulsarSchemaHandlers.java | 4 +-
.../org/apache/pulsar/sql/presto/PulsarSplit.java | 40 ++-
.../pulsar/sql/presto/PulsarSplitManager.java | 16 +-
.../apache/pulsar/sql/presto/SchemaHandler.java | 2 +
.../pulsar/sql/presto/TestPulsarConnector.java | 51 ++--
.../presto/TestPulsarKeyValueSchemaHandler.java | 331 +++++++++++++++++++++
.../presto/TestPulsarPrimitiveSchemaHandler.java | 2 +-
18 files changed, 705 insertions(+), 72 deletions(-)
create mode 100644
pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/KeyValueSchemaHandler.java
create mode 100644
pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarKeyValueSchemaHandler.java
