From 16eb026fdebe67140694e9ccfd2174d795ad6ffd Mon Sep 17 00:00:00 2001
From: Ebere Abanonu <eabanonu@yahoo.com>
Date: Sun, 20 Oct 2024 02:00:01 +0100
Subject: [PATCH] branch-4

---
 .gitignore                                    |  90 ++++
 buildtools/src/main/resources/log4j2.xml      |  37 ++
 .../src/main/resources/pulsar/checkstyle.xml  | 433 ++++++++++++++++++
 .../main/resources/pulsar/suppressions.xml    |  44 ++
 pom.xml                                       | 264 +++++++++++
 pulsar-sql/pom.xml                            | 175 -------
 src/license-header.txt                        |  16 +
 .../conf/{presto => trino}/jvm.config         |   0
 .../{presto_worker.conf => trino_worker.conf} |   0
 ...ntainer.java => TrinoWorkerContainer.java} |   0
 .../integration/{presto => trino}/Stock.java  |   0
 .../{presto => trino}/StockMsg.proto          |   0
 .../{presto => trino}/StockProtoMessage.java  |   0
 .../{presto => trino}/TestBasicPresto.java    |   0
 .../TestPrestoQueryTieredStorage.java         |   0
 .../{presto => trino}/TestPulsarSQLAuth.java  |   0
 .../{presto => trino}/TestPulsarSQLBase.java  |   0
 ...es => trino-coordinator-config.properties} |   0
 ... => trino-follow-worker-config.properties} |   0
 .../LICENSE                                   |   0
 .../pom.xml                                   | 233 ++++------
 .../src/assembly/assembly.xml                 |   0
 .../org/openjdk/jol/info/ClassLayout.java     |   0
 .../org/openjdk/jol/info/package-info.java    |   0
 .../resources/conf/catalog/pulsar.properties  |   0
 .../src/main/resources/conf/config.properties |   0
 .../src/main/resources/conf/jvm.config        |   0
 .../src/main/resources/conf/log.properties    |   0
 .../src/main/resources/launcher.properties    |   0
 .../pom.xml                                   |  13 +-
 .../src/assembly/assembly.xml                 |   0
 .../presto-pulsar => trino-pulsar}/pom.xml    |  33 +-
 .../apache/pulsar/sql/presto/PulsarAuth.java  |   0
 .../pulsar/sql/presto/PulsarColumnHandle.java |   0
 .../sql/presto/PulsarColumnMetadata.java      |   0
 .../pulsar/sql/presto/PulsarConnector.java    |   0
 .../sql/presto/PulsarConnectorCache.java      |   0
 .../sql/presto/PulsarConnectorConfig.java     |   0
 .../sql/presto/PulsarConnectorFactory.java    |   0
 .../pulsar/sql/presto/PulsarConnectorId.java  |   0
 .../presto/PulsarConnectorMetricsTracker.java |   0
 .../sql/presto/PulsarConnectorModule.java     |   0
 .../sql/presto/PulsarConnectorUtils.java      |   0
 .../PulsarDispatchingRowDecoderFactory.java   |   0
 .../sql/presto/PulsarFieldValueProviders.java |   0
 .../sql/presto/PulsarHandleResolver.java      |   0
 .../sql/presto/PulsarInternalColumn.java      |   0
 .../pulsar/sql/presto/PulsarMetadata.java     |   0
 .../pulsar/sql/presto/PulsarPlugin.java       |   0
 .../pulsar/sql/presto/PulsarRecordCursor.java |   0
 .../pulsar/sql/presto/PulsarRecordSet.java    |   0
 .../sql/presto/PulsarRecordSetProvider.java   |   0
 .../pulsar/sql/presto/PulsarRowDecoder.java   |   0
 .../sql/presto/PulsarRowDecoderFactory.java   |   0
 .../apache/pulsar/sql/presto/PulsarSplit.java |   0
 .../pulsar/sql/presto/PulsarSplitManager.java |   0
 .../presto/PulsarSqlSchemaInfoProvider.java   |   0
 .../pulsar/sql/presto/PulsarTableHandle.java  |   0
 .../sql/presto/PulsarTableLayoutHandle.java   |   0
 .../sql/presto/PulsarTopicDescription.java    |   0
 .../sql/presto/PulsarTransactionHandle.java   |   0
 .../decoder/avro/PulsarAvroColumnDecoder.java |   0
 .../decoder/avro/PulsarAvroRowDecoder.java    |   0
 .../avro/PulsarAvroRowDecoderFactory.java     |   0
 .../sql/presto/decoder/avro/package-info.java |   0
 .../decoder/json/PulsarJsonFieldDecoder.java  |   0
 .../decoder/json/PulsarJsonRowDecoder.java    |   0
 .../json/PulsarJsonRowDecoderFactory.java     |   0
 .../sql/presto/decoder/json/package-info.java |   0
 .../primitive/PulsarPrimitiveRowDecoder.java  |   0
 .../PulsarPrimitiveRowDecoderFactory.java     |   0
 .../decoder/primitive/package-info.java       |   0
 .../PulsarProtobufNativeColumnDecoder.java    |   0
 .../PulsarProtobufNativeRowDecoder.java       |   0
 ...PulsarProtobufNativeRowDecoderFactory.java |   0
 .../decoder/protobufnative/package-info.java  |   0
 .../pulsar/sql/presto/package-info.java       |   0
 .../sql/presto/util/CacheSizeAllocator.java   |   0
 .../util/NoStrictCacheSizeAllocator.java      |   0
 .../presto/util/NullCacheSizeAllocator.java   |   0
 .../pulsar/sql/presto/util/package-info.java  |   0
 .../META-INF/services/io.trino.spi.Plugin     |   0
 .../sql/presto/TestCacheSizeAllocator.java    |   0
 .../TestNoStrictCacheSizeAllocator.java       |   0
 .../pulsar/sql/presto/TestPulsarAuth.java     |   0
 .../sql/presto/TestPulsarConnector.java       |   0
 .../sql/presto/TestPulsarConnectorConfig.java |   0
 .../pulsar/sql/presto/TestPulsarMetadata.java |   0
 .../sql/presto/TestPulsarRecordCursor.java    |   0
 .../sql/presto/TestPulsarSplitManager.java    |   0
 .../sql/presto/TestReadChunkedMessages.java   |   0
 .../presto/decoder/AbstractDecoderTester.java |   0
 .../presto/decoder/DecoderTestMessage.java    |   0
 .../sql/presto/decoder/DecoderTestUtil.java   |   0
 .../decoder/avro/AvroDecoderTestUtil.java     |   6 +-
 .../presto/decoder/avro/TestAvroDecoder.java  |   2 +-
 .../decoder/json/JsonDecoderTestUtil.java     |   0
 .../presto/decoder/json/TestJsonDecoder.java  |   0
 .../primitive/PrimitiveDecoderTestUtil.java   |   0
 .../primitive/TestPrimitiveDecoder.java       |   0
 .../ProtobufNativeDecoderTestUtil.java        |   0
 .../decoder/protobufnative/TestMsg.java       |   0
 .../decoder/protobufnative/TestMsg.proto      |   0
 .../TestProtobufNativeDecoder.java            |   0
 104 files changed, 1018 insertions(+), 328 deletions(-)
 create mode 100644 .gitignore
 create mode 100644 buildtools/src/main/resources/log4j2.xml
 create mode 100644 buildtools/src/main/resources/pulsar/checkstyle.xml
 create mode 100644 buildtools/src/main/resources/pulsar/suppressions.xml
 create mode 100644 pom.xml
 delete mode 100644 pulsar-sql/pom.xml
 create mode 100644 src/license-header.txt
 rename tests/docker-images/latest-version-image/conf/{presto => trino}/jvm.config (100%)
 rename tests/docker-images/latest-version-image/conf/{presto_worker.conf => trino_worker.conf} (100%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/{PrestoWorkerContainer.java => TrinoWorkerContainer.java} (100%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/{presto => trino}/Stock.java (100%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/{presto => trino}/StockMsg.proto (100%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/{presto => trino}/StockProtoMessage.java (100%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/{presto => trino}/TestBasicPresto.java (100%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/{presto => trino}/TestPrestoQueryTieredStorage.java (100%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/{presto => trino}/TestPulsarSQLAuth.java (100%)
 rename tests/integration/src/test/java/org/apache/pulsar/tests/integration/{presto => trino}/TestPulsarSQLBase.java (100%)
 rename tests/integration/src/test/resources/{presto-coordinator-config.properties => trino-coordinator-config.properties} (100%)
 rename tests/integration/src/test/resources/{presto-follow-worker-config.properties => trino-follow-worker-config.properties} (100%)
 rename {pulsar-sql/presto-distribution => trino-distribution}/LICENSE (100%)
 rename {pulsar-sql/presto-distribution => trino-distribution}/pom.xml (66%)
 rename {pulsar-sql/presto-distribution => trino-distribution}/src/assembly/assembly.xml (100%)
 rename {pulsar-sql/presto-distribution => trino-distribution}/src/main/java/org/openjdk/jol/info/ClassLayout.java (100%)
 rename {pulsar-sql/presto-distribution => trino-distribution}/src/main/java/org/openjdk/jol/info/package-info.java (100%)
 rename {pulsar-sql/presto-distribution => trino-distribution}/src/main/resources/conf/catalog/pulsar.properties (100%)
 rename {pulsar-sql/presto-distribution => trino-distribution}/src/main/resources/conf/config.properties (100%)
 rename {pulsar-sql/presto-distribution => trino-distribution}/src/main/resources/conf/jvm.config (100%)
 rename {pulsar-sql/presto-distribution => trino-distribution}/src/main/resources/conf/log.properties (100%)
 rename {pulsar-sql/presto-distribution => trino-distribution}/src/main/resources/launcher.properties (100%)
 rename {pulsar-sql/presto-pulsar-plugin => trino-pulsar-plugin}/pom.xml (88%)
 rename {pulsar-sql/presto-pulsar-plugin => trino-pulsar-plugin}/src/assembly/assembly.xml (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/pom.xml (89%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarAuth.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnHandle.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnMetadata.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarConnector.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorConfig.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorFactory.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorId.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorMetricsTracker.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorModule.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorUtils.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarDispatchingRowDecoderFactory.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarFieldValueProviders.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarHandleResolver.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarInternalColumn.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarPlugin.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordSet.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordSetProvider.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarRowDecoder.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarRowDecoderFactory.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarSplit.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarTableHandle.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarTableLayoutHandle.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarTopicDescription.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/PulsarTransactionHandle.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroColumnDecoder.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroRowDecoder.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroRowDecoderFactory.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/package-info.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonFieldDecoder.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonRowDecoder.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonRowDecoderFactory.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/json/package-info.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/PulsarPrimitiveRowDecoder.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/PulsarPrimitiveRowDecoderFactory.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/package-info.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeColumnDecoder.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeRowDecoder.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeRowDecoderFactory.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/package-info.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/package-info.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/util/CacheSizeAllocator.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/util/NoStrictCacheSizeAllocator.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/util/NullCacheSizeAllocator.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/java/org/apache/pulsar/sql/presto/util/package-info.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/main/resources/META-INF/services/io.trino.spi.Plugin (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/TestCacheSizeAllocator.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/TestNoStrictCacheSizeAllocator.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/TestPulsarAuth.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnector.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnectorConfig.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/TestPulsarMetadata.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/TestPulsarRecordCursor.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/TestPulsarSplitManager.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/TestReadChunkedMessages.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/decoder/AbstractDecoderTester.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/decoder/DecoderTestMessage.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/decoder/DecoderTestUtil.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/AvroDecoderTestUtil.java (98%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/TestAvroDecoder.java (99%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/decoder/json/JsonDecoderTestUtil.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/decoder/json/TestJsonDecoder.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/decoder/primitive/PrimitiveDecoderTestUtil.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/decoder/primitive/TestPrimitiveDecoder.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/ProtobufNativeDecoderTestUtil.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestMsg.java (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestMsg.proto (100%)
 rename {pulsar-sql/presto-pulsar => trino-pulsar}/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestProtobufNativeDecoder.java (100%)

diff --git a/.gitignore b/.gitignore
new file mode 100644
index 0000000..297f31d
--- /dev/null
+++ b/.gitignore
@@ -0,0 +1,90 @@
+status.html
+.metadata
+test-output
+test-results
+dependency-reduced-pom.xml
+logs
+/data
+pulsar-broker/data/
+pulsar-broker/tmp.*
+pulsar-broker/src/test/resources/log4j2.yaml
+pulsar-functions/worker/test-tenant/
+pulsar-broker/src/test/resources/pulsar-functions-api-examples.jar
+pulsar-functions/runtime/src/test/resources/
+pulsar-functions/worker/src/test/resources/
+*.log
+*.nar
+
+*.versionsBackup
+*/bin
+
+# Eclipse
+.classpath
+.project
+.settings/
+.recommenders/
+.factorypath
+
+# Intellij
+.idea/
+*.iml
+*.iws
+
+# Mac
+**/.DS_Store
+
+# VisualStudioCode artifacts
+.vscode/
+
+# Maven
+log/
+target/
+
+# Python
+*.pyc
+
+# Perf tools
+*.hgrm
+
+# tmp files
+*.pid
+
+# Generated website
+generated-site/
+
+# Ansible and Terraform artifacts
+deployment/terraform-ansible/deploy-pulsar.retry
+deployment/terraform-ansible/aws/.terraform/
+deployment/terraform-ansible/aws/.terraform.tfstate.lock.info
+deployment/terraform-ansible/aws/terraform.tfstate
+deployment/terraform-ansible/aws/terraform.tfstate.backup
+
+# Vagrant
+**/.vagrant
+
+
+pulsar-client-cpp/python/pkg/osx/*/*.bak
+pulsar-client-cpp/python/pkg/osx/*/*.whl
+pulsar-client-cpp/python/wheelhouse
+
+# CI generated files
+.repository
+docker.debug-info
+
+# Yarn
+
+**/yarn.lock
+
+# docusaurus
+
+**/website/i18n/*
+**/website/translated_docs*
+**/website/brodocs/index.html
+**/website/brodocs/navData.js
+**/website/brodocs/documents/*.md
+
+# Avro
+examples/flink/src/main/java/org/apache/flink/avro/generated
+pulsar-flink/src/test/java/org/apache/flink/avro/generated
+pulsar-client/src/test/java/org/apache/pulsar/client/avro/generated
+/build/
diff --git a/buildtools/src/main/resources/log4j2.xml b/buildtools/src/main/resources/log4j2.xml
new file mode 100644
index 0000000..2fdc2d0
--- /dev/null
+++ b/buildtools/src/main/resources/log4j2.xml
@@ -0,0 +1,37 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
+<Configuration status="INFO">
+    <Appenders>
+        <Console name="Console" target="SYSTEM_OUT">
+            <PatternLayout pattern="%d{HH:mm:ss.SSS} [%t:%C@%L] %-5level %logger{36} - %msg%n" />
+        </Console>
+    </Appenders>
+    <Loggers>
+        <Root level="warn">
+            <AppenderRef ref="Console" />
+        </Root>
+        <Logger name="org.eclipse.jetty" level="info"/>
+        <Logger name="org.apache.pulsar" level="info"/>
+        <Logger name="org.apache.bookkeeper" level="info"/>
+        <Logger name="org.apache.kafka" level="info"/>
+    </Loggers>
+</Configuration>
diff --git a/buildtools/src/main/resources/pulsar/checkstyle.xml b/buildtools/src/main/resources/pulsar/checkstyle.xml
new file mode 100644
index 0000000..b46c8bf
--- /dev/null
+++ b/buildtools/src/main/resources/pulsar/checkstyle.xml
@@ -0,0 +1,433 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
+<!DOCTYPE module PUBLIC
+        "-//Puppy Crawl//DTD Check Configuration 1.3//EN"
+        "http://www.puppycrawl.com/dtds/configuration_1_3.dtd">
+
+<!-- This is a checkstyle configuration file. For descriptions of
+what the following rules do, please see the checkstyle configuration
+page at http://checkstyle.sourceforge.net/config.html -->
+
+<module name="Checker">
+
+    <module name="SuppressWarningsFilter" />
+
+    <module name="FileTabCharacter">
+        <!-- Checks that there are no tab characters in the file. -->
+    </module>
+
+    <module name="RegexpSingleline">
+        <!-- Checks that TODOs don't have stuff in parenthesis, e.g., username. -->
+        <property name="format" value="((//.*)|(\*.*))TODO\(" />
+        <property name="message" value="TODO comments must not include usernames." />
+        <property name="severity" value="error" />
+    </module>
+
+    <module name="RegexpSingleline">
+        <property name="format" value="\s+$"/>
+        <property name="message" value="Trailing whitespace"/>
+        <property name="severity" value="error"/>
+    </module>
+
+    <module name="RegexpSingleline">
+        <property name="format" value="Throwables.propagate\("/>
+        <property name="message" value="Throwables.propagate is deprecated"/>
+        <property name="severity" value="error"/>
+    </module>
+
+    <!-- Prevent *Tests.java as tools may not pick them up -->
+    <module name="RegexpOnFilename">
+        <property name="fileNamePattern" value=".*Tests\.java$" />
+    </module>
+
+    <!-- Allow use of comment to suppress javadocstyle -->
+    <module name="SuppressionCommentFilter">
+        <property name="offCommentFormat" value="CHECKSTYLE.OFF\: ([\w\|]+)"/>
+        <property name="onCommentFormat" value="CHECKSTYLE.ON\: ([\w\|]+)"/>
+        <property name="checkFormat" value="$1"/>
+    </module>
+    <module name="SuppressionFilter">
+        <property name="file" value="${checkstyle.suppressions.file}" default="suppressions.xml" />
+    </module>
+
+    <!-- Check that every module has a package-info.java -->
+    <module name="JavadocPackage"/>
+
+    <!-- All Java AST specific tests live under TreeWalker module. -->
+    <module name="TreeWalker">
+
+        <module name="SuppressWarningsHolder" />
+
+        <module name="TodoComment">
+            <!-- Checks that disallowed strings are not used in comments.  -->
+            <property name="format" value="(FIXME)|(XXX)|(@author)" />
+        </module>
+
+        <!--
+
+        IMPORT CHECKS
+
+        -->
+
+        <module name="RedundantImport">
+            <!-- Checks for redundant import statements. -->
+            <property name="severity" value="error"/>
+            <message key="import.redundancy"
+                     value="Redundant import {0}."/>
+        </module>
+
+        <module name="ImportOrder">
+            <property name="severity" value="error"/>
+            <!-- This ensures that static imports go first. -->
+            <property name="option" value="top"/>
+            <property name="sortStaticImportsAlphabetically" value="true"/>
+            <property name="tokens" value="STATIC_IMPORT, IMPORT"/>
+            <message key="import.ordering"
+                     value="Import {0} appears after other imports that it should precede"/>
+        </module>
+
+        <module name="AvoidStarImport">
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="IllegalImport">
+            <property name="illegalPkgs" value="autovalue.shaded, avro.shaded, bk-shade, com.google.api.client.repackaged, com.google.appengine.repackaged, io.netty.util.internal"/>
+        </module>
+
+        <module name="RedundantModifier">
+            <!-- Checks for redundant modifiers on various symbol definitions.
+              See: http://checkstyle.sourceforge.net/config_modifier.html#RedundantModifier
+            -->
+            <property name="tokens" value="METHOD_DEF, VARIABLE_DEF, ANNOTATION_FIELD_DEF, INTERFACE_DEF, CLASS_DEF, ENUM_DEF"/>
+        </module>
+
+        <!--
+            IllegalImport cannot blacklist classes, and c.g.api.client.util is used for some shaded
+            code and some useful code. So we need to fall back to Regexp.
+        -->
+        <module name="RegexpSinglelineJava">
+            <property name="format" value="com\.google\.api\.client\.util\.(ByteStreams|Charsets|Collections2|Joiner|Lists|Maps|Objects|Preconditions|Sets|Strings|Throwables)"/>
+        </module>
+
+        <!--
+             Require static importing from Preconditions.
+        -->
+        <module name="RegexpSinglelineJava">
+            <property name="format" value="^import com.google.common.base.Preconditions;$"/>
+            <property name="message" value="Static import functions from Guava Preconditions"/>
+        </module>
+
+        <module name="UnusedImports">
+            <property name="severity" value="error"/>
+            <property name="processJavadoc" value="true"/>
+            <message key="import.unused"
+                     value="Unused import: {0}."/>
+        </module>
+
+        <!--
+
+        JAVADOC CHECKS
+
+        -->
+
+        <!-- Checks for Javadoc comments.                     -->
+        <!-- See http://checkstyle.sf.net/config_javadoc.html -->
+        <module name="JavadocMethod">
+            <property name="scope" value="protected"/>
+            <property name="severity" value="error"/>
+            <property name="allowMissingJavadoc" value="true"/>
+            <property name="allowMissingParamTags" value="true"/>
+            <property name="allowMissingReturnTag" value="true"/>
+            <property name="allowMissingThrowsTags" value="true"/>
+            <property name="allowThrowsTagsForSubclasses" value="true"/>
+            <property name="allowUndeclaredRTE" value="true"/>
+        </module>
+
+        <!-- Check that paragraph tags are used correctly in Javadoc. -->
+        <module name="JavadocParagraph"/>
+
+        <module name="JavadocType">
+            <property name="scope" value="protected"/>
+            <property name="severity" value="error"/>
+            <property name="allowMissingParamTags" value="true"/>
+        </module>
+
+        <module name="JavadocStyle">
+            <property name="severity" value="error"/>
+            <property name="checkHtml" value="true"/>
+        </module>
+
+        <!--
+
+        NAMING CHECKS
+
+        -->
+
+        <!-- Item 38 - Adhere to generally accepted naming conventions -->
+
+        <module name="PackageName">
+            <!-- Validates identifiers for package names against the
+              supplied expression. -->
+            <!-- Here the default checkstyle rule restricts package name parts to
+              seven characters, this is not in line with common practice at Google.
+            -->
+            <property name="format" value="^[a-z]+(\.[a-z][a-z0-9]{1,})*$"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="TypeNameCheck">
+            <!-- Validates static, final fields against the
+            expression "^[A-Z][a-zA-Z0-9]*$". -->
+            <metadata name="altname" value="TypeName"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="ConstantNameCheck">
+            <!-- Validates non-private, static, final fields against the supplied
+            public/package final fields "^[A-Z][A-Z0-9]*(_[A-Z0-9]+)*$". -->
+            <metadata name="altname" value="ConstantName"/>
+            <property name="applyToPublic" value="true"/>
+            <property name="applyToProtected" value="true"/>
+            <property name="applyToPackage" value="true"/>
+            <property name="applyToPrivate" value="false"/>
+            <property name="format" value="^([A-Z][A-Za-z0-9_]*|FLAG_.*)$"/>
+            <message key="name.invalidPattern"
+                     value="Variable ''{0}'' should be in ALL_CAPS (if it is a constant) or be private (otherwise)."/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="StaticVariableNameCheck">
+            <!-- Validates static, non-final fields against the supplied
+            expression "^[a-z][a-zA-Z0-9]*_?$". -->
+            <metadata name="altname" value="StaticVariableName"/>
+            <property name="applyToPublic" value="true"/>
+            <property name="applyToProtected" value="true"/>
+            <property name="applyToPackage" value="true"/>
+            <property name="applyToPrivate" value="true"/>
+            <property name="format" value="^[a-z][a-zA-Z0-9]*_?$"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="MemberNameCheck">
+            <!-- Validates non-static members against the supplied expression. -->
+            <metadata name="altname" value="MemberName"/>
+            <property name="applyToPublic" value="true"/>
+            <property name="applyToProtected" value="true"/>
+            <property name="applyToPackage" value="true"/>
+            <property name="applyToPrivate" value="true"/>
+            <property name="format" value="^[a-z][a-zA-Z0-9]*$"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="MethodNameCheck">
+            <!-- Validates identifiers for method names. -->
+            <metadata name="altname" value="MethodName"/>
+            <property name="format" value="(^[a-z][a-zA-Z0-9]*(_[a-zA-Z0-9]+)*$|Void)"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="ParameterName">
+            <!-- Validates identifiers for method parameters against the
+              expression "^[a-z][a-zA-Z0-9]*$". -->
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="LocalFinalVariableName">
+            <!-- Validates identifiers for local final variables against the
+              expression "^[a-z][a-zA-Z0-9]*$". -->
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="LocalVariableName">
+            <!-- Validates identifiers for local variables against the
+              expression "^[a-z][a-zA-Z0-9]*$". -->
+            <property name="severity" value="error"/>
+        </module>
+
+        <!-- Type parameters must be either one of the four blessed letters
+        T, K, V, W, X or else be capital-case terminated with a T,
+        such as MyGenericParameterT -->
+        <module name="ClassTypeParameterName">
+            <property name="format" value="^(((T|K|V|W|X|R)[0-9]*)|([A-Z][a-z][a-zA-Z]*))$"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="MethodTypeParameterName">
+            <property name="format" value="^(((T|K|V|W|X|R)[0-9]*)|([A-Z][a-z][a-zA-Z]*T))$"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="InterfaceTypeParameterName">
+            <property name="format" value="^(((T|K|V|W|X|R)[0-9]*)|([A-Z][a-z][a-zA-Z]*T))$"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <!--
+
+        LENGTH and CODING CHECKS
+
+        -->
+
+        <module name="LineLength">
+            <!-- Checks if a line is too long. -->
+            <property name="max" value="120"/>
+            <property name="severity" value="error"/>
+
+            <!--
+              The default ignore pattern exempts the following elements:
+                - import statements
+                - long URLs inside comments
+            -->
+
+            <property name="ignorePattern"
+                      value="^(package .*;\s*)|(import .*;\s*)|( *\* .*https?://.*)$"/>
+        </module>
+
+        <module name="LeftCurly">
+            <!-- Checks for placement of the left curly brace ('{'). -->
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="RightCurly">
+            <!-- Checks right curlies on CATCH, ELSE, and TRY blocks are on
+            the same line. e.g., the following example is fine:
+            <pre>
+              if {
+                ...
+              } else
+            </pre>
+            -->
+            <!-- This next example is not fine:
+            <pre>
+              if {
+                ...
+              }
+              else
+            </pre>
+            -->
+            <property name="option" value="same"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <!-- Checks for braces around if and else blocks -->
+        <module name="NeedBraces">
+            <property name="severity" value="error"/>
+            <property name="tokens" value="LITERAL_IF, LITERAL_ELSE, LITERAL_FOR, LITERAL_WHILE, LITERAL_DO"/>
+        </module>
+
+        <module name="UpperEll">
+            <!-- Checks that long constants are defined with an upper ell.-->
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="FallThrough">
+            <!-- Warn about falling through to the next case statement.  Similar to
+            javac -Xlint:fallthrough, but the check is suppressed if a single-line comment
+            on the last non-blank line preceding the fallen-into case contains 'fall through' (or
+            some other variants that we don't publicized to promote consistency).
+            -->
+            <property name="reliefPattern"
+                      value="fall through|Fall through|fallthru|Fallthru|falls through|Falls through|fallthrough|Fallthrough|No break|NO break|no break|continue on"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <!-- Checks for over-complicated boolean expressions. -->
+        <module name="SimplifyBooleanExpression"/>
+
+        <!-- Detects empty statements (standalone ";" semicolon). -->
+        <module name="EmptyStatement"/>
+
+        <!--
+
+        WHITESPACE CHECKS
+
+        -->
+
+        <module name="WhitespaceAround">
+            <!-- Checks that various tokens are surrounded by whitespace.
+                 This includes most binary operators and keywords followed
+                 by regular or curly braces.
+            -->
+            <property name="tokens" value="ASSIGN, BAND, BAND_ASSIGN, BOR,
+        BOR_ASSIGN, BSR, BSR_ASSIGN, BXOR, BXOR_ASSIGN, COLON, DIV, DIV_ASSIGN,
+        EQUAL, GE, GT, LAND, LE, LITERAL_CATCH, LITERAL_DO, LITERAL_ELSE,
+        LITERAL_FINALLY, LITERAL_FOR, LITERAL_IF, LITERAL_RETURN,
+        LITERAL_SYNCHRONIZED, LITERAL_TRY, LITERAL_WHILE, LOR, LT, MINUS,
+        MINUS_ASSIGN, MOD, MOD_ASSIGN, NOT_EQUAL, PLUS, PLUS_ASSIGN, QUESTION,
+        SL, SL_ASSIGN, SR_ASSIGN, STAR, STAR_ASSIGN"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="WhitespaceAfter">
+            <!-- Checks that commas, semicolons and typecasts are followed by
+                 whitespace.
+            -->
+            <property name="tokens" value="COMMA, SEMI, TYPECAST"/>
+        </module>
+
+        <module name="NoWhitespaceAfter">
+            <!-- Checks that there is no whitespace after various unary operators.
+                 Linebreaks are allowed.
+            -->
+            <property name="tokens" value="BNOT, DEC, DOT, INC, LNOT, UNARY_MINUS,
+        UNARY_PLUS"/>
+            <property name="allowLineBreaks" value="true"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="NoWhitespaceBefore">
+            <!-- Checks that there is no whitespace before various unary operators.
+                 Linebreaks are allowed.
+            -->
+            <property name="tokens" value="SEMI, DOT, POST_DEC, POST_INC"/>
+            <property name="allowLineBreaks" value="true"/>
+            <property name="severity" value="error"/>
+        </module>
+
+        <module name="OperatorWrap">
+            <!-- Checks that operators like + and ? appear at newlines rather than
+                 at the end of the previous line.
+            -->
+            <property name="option" value="NL"/>
+            <property name="tokens" value="BAND, BOR, BSR, BXOR, DIV, EQUAL,
+        GE, GT, LAND, LE, LITERAL_INSTANCEOF, LOR, LT, MINUS, MOD,
+        NOT_EQUAL, PLUS, QUESTION, SL, SR, STAR "/>
+        </module>
+
+        <module name="OperatorWrap">
+            <!-- Checks that assignment operators are at the end of the line. -->
+            <property name="option" value="eol"/>
+            <property name="tokens" value="ASSIGN"/>
+        </module>
+
+        <module name="ParenPad">
+            <!-- Checks that there is no whitespace before close parens or after
+                 open parens.
+            -->
+            <property name="severity" value="error"/>
+        </module>
+
+        <!-- Required to support SuppressWarningsComment -->
+        <module name="FileContentsHolder"/>
+
+    </module>
+</module>
diff --git a/buildtools/src/main/resources/pulsar/suppressions.xml b/buildtools/src/main/resources/pulsar/suppressions.xml
new file mode 100644
index 0000000..d6d38a2
--- /dev/null
+++ b/buildtools/src/main/resources/pulsar/suppressions.xml
@@ -0,0 +1,44 @@
+<?xml version="1.0"?>
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
+<!DOCTYPE suppressions PUBLIC
+        "-//Puppy Crawl//DTD Suppressions 1.1//EN"
+        "http://www.puppycrawl.com/dtds/suppressions_1_1.dtd">
+
+<suppressions>
+    <suppress checks="JavadocPackage" files=".*[\\/]src[\\/]test[\\/].*"/>
+    <suppress checks="JavadocPackage" files=".*[\\/]maven-archetypes[\\/].*"/>
+    <suppress checks="JavadocPackage" files=".*[\\/]examples[\\/].*"/>
+
+    <!-- suppress javadoc check for impl classes -->
+    <suppress checks="JavadocType" files=".*Impl\.java$" />
+
+    <!-- suppress all checks in the generated directories -->
+    <suppress checks=".*" files=".+[\\/]generated[\\/].+\.java" />
+    <suppress checks=".*" files=".+[\\/]generated-sources[\\/].+\.java" />
+    <suppress checks=".*" files=".+[\\/]generated-test-sources[\\/].+\.java" />
+
+    <!-- suppress all checks in the copied code -->
+    <suppress checks=".*" files=".+[\\/]com[\\/]scurrilous[\\/]circe[\\/].+\.java" />
+    
+    <suppress checks=".*" files="MLDataFormats.java" />
+    <suppress checks=".*" files="BitSetRecyclable.java" />
+</suppressions>
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..4abd336
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,264 @@
+<!--
+
+    Licensed to the Apache Software Foundation (ASF) under one
+    or more contributor license agreements.  See the NOTICE file
+    distributed with this work for additional information
+    regarding copyright ownership.  The ASF licenses this file
+    to you under the Apache License, Version 2.0 (the
+    "License"); you may not use this file except in compliance
+    with the License.  You may obtain a copy of the License at
+
+      http://www.apache.org/licenses/LICENSE-2.0
+
+    Unless required by applicable law or agreed to in writing,
+    software distributed under the License is distributed on an
+    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+    KIND, either express or implied.  See the License for the
+    specific language governing permissions and limitations
+    under the License.
+
+-->
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <packaging>pom</packaging>
+    <parent>
+        <groupId>org.apache</groupId>
+        <artifactId>apache</artifactId>
+        <version>29</version>
+    </parent>
+
+    <groupId>org.apache.pulsar</groupId>
+    <artifactId>pulsar-sql</artifactId>
+    <version>4.1.0-SNAPSHOT</version>
+    <name>Pulsar SQL :: Parent</name>
+
+    <modules>
+        <module>trino-pulsar</module>
+        <module>trino-pulsar-plugin</module>
+        <module>trino-distribution</module>
+    </modules>
+    <properties>
+        <project.build.targetJdk>22</project.build.targetJdk>
+        <!-- for reproducible build support, updated by release plugin -->
+        <project.build.outputTimestamp>2024-10-03T18:16:23Z</project.build.outputTimestamp>
+        <!-- TODO remove this property when no module overrides it -->
+        <trino.error-prone.guarded-by>ERROR</trino.error-prone.guarded-by>
+
+        <air.check.skip-spotbugs>true</air.check.skip-spotbugs>
+        <air.check.skip-pmd>true</air.check.skip-pmd>
+        <air.check.skip-jacoco>true</air.check.skip-jacoco>
+        <air.java.version>22.0.0</air.java.version>
+        <air.javadoc.lint>syntax,reference,html,-missing</air.javadoc.lint>
+        <air.modernizer.java-version>8</air.modernizer.java-version>
+        <air.release.preparation-goals>clean verify -DskipTests</air.release.preparation-goals>
+        <!--
+          America/Bahia_Banderas has:
+           - offset change since 1970 (offset Jan 1970: -08:00, offset Jan 2018: -06:00)
+           - DST (e.g. at 2017-04-02 02:00:00 clocks turned forward 1 hour; 2017-10-29 02:00:00 clocks turned backward 1 hour)
+           - has forward offset change on first day of epoch (1970-01-01 00:00:00 clocks turned forward 1 hour)
+           - had forward change at midnight (1970-01-01 00:00:00 clocks turned forward 1 hour)
+          -->
+        <air.test.timezone>America/Bahia_Banderas</air.test.timezone>
+        <!-- Be conservative about memory allotment, because tests start background process (e.g. docker containers) -->
+        <air.test.jvmsize>3g</air.test.jvmsize>
+        <!-- G1 default region size for a small heap is 1MB. Tests (TestHiveConnectorTest.testMultipleWritersWhenTaskScaleWritersIsEnabled) in particular
+             were observed allocating large number of byte[] of about 1.6MB in size, thus being treated as humongous allocations and preventing heap saturation.
+             Force bigger region size in attempt to help G1 utilize heap fully. -->
+
+        <air.test.jvm.additional-arguments>${air.test.jvm.additional-arguments.default}</air.test.jvm.additional-arguments>
+        <airlift.version>273</airlift.version>
+        <avro.version>1.12.0</avro.version>
+        <docker.images.version>100</docker.images.version>
+        <drift.version>1.22</drift.version>
+        <!-- temporary downgrade due to https://github.com/google/error-prone/issues/4598 -->
+        <errorprone.version>2.32.0</errorprone.version>
+        <jna.version>5.15.0</jna.version>
+        <joda.version>2.12.7</joda.version>
+        <jsonwebtoken.version>0.12.6</jsonwebtoken.version>
+        <jts.version>1.20.0</jts.version>
+        <okio.version>3.9.1</okio.version>
+        <packaging.version>${airlift.version}</packaging.version>
+        <plugin.failsafe.version>${plugin.surefire.version}</plugin.failsafe.version>
+        <pulsar.version>4.0.0-preview.1</pulsar.version>
+        <jackson.version>2.18.0</jackson.version>
+        <trino.version>461</trino.version>
+        <extraJavaVectorArgs>--add-modules=jdk.incubator.vector</extraJavaVectorArgs>
+        <!--
+        Instructs Provisio to write runtime dependencies in the format groupId_artifactId-version.jar.
+        This is important to avoid overwriting dependencies with the same name and version but different groupId.
+        Since 1.1.0, the default behaviour for such conflicts changed from overwriting the artifact to failing the build.
+        -->
+        <provisio.fallbackTargetFileNameMode>GA</provisio.fallbackTargetFileNameMode>
+    </properties>
+
+    <dependencyManagement>
+        <dependencies>
+            <dependency>
+                <groupId>com.fasterxml.jackson.jaxrs</groupId>
+                <artifactId>jackson-jaxrs-json-provider</artifactId>
+                <version>${jackson.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.fasterxml.jackson.core</groupId>
+                <artifactId>jackson-core</artifactId>
+                <version>${jackson.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.fasterxml.jackson.core</groupId>
+                <artifactId>jackson-databind</artifactId>
+                <version>${jackson.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.fasterxml.jackson.core</groupId>
+                <artifactId>jackson-annotations</artifactId>
+                <version>${jackson.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.fasterxml.jackson.jaxrs</groupId>
+                <artifactId>jackson-jaxrs-base </artifactId>
+                <version>${jackson.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.fasterxml.jackson.datatype</groupId>
+                <artifactId>jackson-datatype-joda</artifactId>
+                <version>${jackson.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.fasterxml.jackson.dataformat</groupId>
+                <artifactId>jackson-dataformat-yaml</artifactId>
+                <version>${jackson.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.fasterxml.jackson.module</groupId>
+                <artifactId>jackson-module-jsonSchema</artifactId>
+                <version>${jackson.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.fasterxml.jackson.datatype</groupId>
+                <artifactId>jackson-datatype-guava</artifactId>
+                <version>${jackson.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>io.airlift</groupId>
+                <artifactId>bom</artifactId>
+                <version>${airlift.version}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+
+            <dependency>
+                <groupId>org.apache.pulsar</groupId>
+                <artifactId>pulsar-bom</artifactId>
+                <version>${pulsar.version}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+
+            <dependency>
+                <groupId>com.google.errorprone</groupId>
+                <artifactId>error_prone_annotations</artifactId>
+                <version>${errorprone.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>org.testcontainers</groupId>
+                <artifactId>testcontainers-bom</artifactId>
+                <version>1.20.2</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+
+            <dependency>
+                <groupId>com.fasterxml.jackson.datatype</groupId>
+                <artifactId>jackson-datatype-jdk8</artifactId>
+                <version>${jackson.version}</version>
+            </dependency>
+
+            <dependency>
+                <groupId>com.fasterxml.jackson.datatype</groupId>
+                <artifactId>jackson-datatype-jsr310</artifactId>
+                <version>${jackson.version}</version>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-checkstyle-plugin</artifactId>
+                <executions>
+                    <execution>
+                        <id>checkstyle</id>
+                        <phase>verify</phase>
+                        <goals>
+                            <goal>check</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+
+    <profiles>
+        <profile>
+            <id>main</id>
+            <activation>
+                <property>
+                    <name>disableSqlMainProfile</name>
+                    <!-- always active unless true is passed as a value -->
+                    <value>!true</value>
+                </property>
+            </activation>
+            <modules>
+                <module>trino-pulsar</module>
+                <module>trino-pulsar-plugin</module>
+                <module>trino-distribution</module>
+            </modules>
+        </profile>
+        <profile>
+            <id>pulsar-sql-tests</id>
+            <modules>
+                <module>trino-pulsar</module>
+                <module>trino-pulsar-plugin</module>
+                <module>trino-distribution</module>
+            </modules>
+        </profile>
+        <!--
+        The only working way for OWASP dependency checker plugin
+        to exclude module when failBuildOnCVSS is used
+        in the root pom's plugin.
+        -->
+        <profile>
+            <id>owasp-dependency-check</id>
+            <build>
+                <plugins>
+                    <plugin>
+                        <groupId>org.owasp</groupId>
+                        <artifactId>dependency-check-maven</artifactId>
+                        <version>${dependency-check-maven.version}</version>
+                        <executions>
+                            <execution>
+                                <goals>
+                                    <goal>aggregate</goal>
+                                </goals>
+                                <phase>none</phase>
+                            </execution>
+                        </executions>
+                    </plugin>
+                </plugins>
+            </build>
+        </profile>
+    </profiles>
+</project>
diff --git a/pulsar-sql/pom.xml b/pulsar-sql/pom.xml
deleted file mode 100644
index 22a4730..0000000
--- a/pulsar-sql/pom.xml
+++ /dev/null
@@ -1,175 +0,0 @@
-<!--
-
-    Licensed to the Apache Software Foundation (ASF) under one
-    or more contributor license agreements.  See the NOTICE file
-    distributed with this work for additional information
-    regarding copyright ownership.  The ASF licenses this file
-    to you under the Apache License, Version 2.0 (the
-    "License"); you may not use this file except in compliance
-    with the License.  You may obtain a copy of the License at
-
-      http://www.apache.org/licenses/LICENSE-2.0
-
-    Unless required by applicable law or agreed to in writing,
-    software distributed under the License is distributed on an
-    "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
-    KIND, either express or implied.  See the License for the
-    specific language governing permissions and limitations
-    under the License.
-
--->
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
-    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
-    <modelVersion>4.0.0</modelVersion>
-    <packaging>pom</packaging>
-    <parent>
-        <groupId>org.apache.pulsar</groupId>
-        <artifactId>pulsar</artifactId>
-        <version>3.0.8-SNAPSHOT</version>
-    </parent>
-
-    <artifactId>pulsar-sql</artifactId>
-    <name>Pulsar SQL :: Parent</name>
-
-    <properties>
-        <!-- keep using okhttp3 3.x for Presto -->
-        <okhttp3.version>3.14.9</okhttp3.version>
-        <!-- use okio version that matches the okhttp3 version -->
-        <okio.version>1.17.2</okio.version>
-        <airlift.version>213</airlift.version>
-    </properties>
-
-    <dependencyManagement>
-        <dependencies>
-            <!-- keep using okhttp3 3.x for Presto -->
-            <dependency>
-                <groupId>com.squareup.okhttp3</groupId>
-                <artifactId>okhttp</artifactId>
-                <version>${okhttp3.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>com.squareup.okhttp3</groupId>
-                <artifactId>okhttp-urlconnection</artifactId>
-                <version>${okhttp3.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>com.squareup.okhttp3</groupId>
-                <artifactId>logging-interceptor</artifactId>
-                <version>${okhttp3.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>com.squareup.okio</groupId>
-                <artifactId>okio</artifactId>
-                <version>${okio.version}</version>
-            </dependency>
-
-            <!-- force specific version of jline, see https://github.com/scala/scala/pull/9807 -->
-            <dependency>
-                <groupId>org.jline</groupId>
-                <artifactId>jline-reader</artifactId>
-                <version>${jline3.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>org.jline</groupId>
-                <artifactId>jline-terminal</artifactId>
-                <version>${jline3.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>org.jline</groupId>
-                <artifactId>jline-terminal-jna</artifactId>
-                <version>${jline3.version}</version>
-            </dependency>
-
-            <!-- force specific version of slf4j -->
-            <dependency>
-                <groupId>org.slf4j</groupId>
-                <artifactId>log4j-over-slf4j</artifactId>
-                <version>${slf4j.version}</version>
-            </dependency>
-            <dependency>
-                <groupId>org.slf4j</groupId>
-                <artifactId>slf4j-jdk14</artifactId>
-                <version>${slf4j.version}</version>
-            </dependency>
-
-            <dependency>
-                <groupId>io.airlift</groupId>
-                <artifactId>bom</artifactId>
-                <version>${airlift.version}</version>
-                <type>pom</type>
-                <scope>import</scope>
-            </dependency>
-        </dependencies>
-    </dependencyManagement>
-
-
-    <build>
-        <plugins>
-            <plugin>
-                <groupId>org.apache.maven.plugins</groupId>
-                <artifactId>maven-checkstyle-plugin</artifactId>
-                <executions>
-                    <execution>
-                        <id>checkstyle</id>
-                        <phase>verify</phase>
-                        <goals>
-                            <goal>check</goal>
-                        </goals>
-                    </execution>
-                </executions>
-            </plugin>
-        </plugins>
-    </build>
-
-    <profiles>
-        <profile>
-            <id>main</id>
-            <activation>
-                <property>
-                    <name>disableSqlMainProfile</name>
-                    <!-- always active unless true is passed as a value -->
-                    <value>!true</value>
-                </property>
-            </activation>
-            <modules>
-                <module>presto-pulsar</module>
-                <module>presto-pulsar-plugin</module>
-                <module>presto-distribution</module>
-            </modules>
-        </profile>
-        <profile>
-            <id>pulsar-sql-tests</id>
-            <modules>
-                <module>presto-pulsar</module>
-                <module>presto-pulsar-plugin</module>
-                <module>presto-distribution</module>
-            </modules>
-        </profile>
-        <!--
-        The only working way for OWASP dependency checker plugin
-        to exclude module when failBuildOnCVSS is used
-        in the root pom's plugin.
-        -->
-        <profile>
-            <id>owasp-dependency-check</id>
-            <build>
-                <plugins>
-                    <plugin>
-                        <groupId>org.owasp</groupId>
-                        <artifactId>dependency-check-maven</artifactId>
-                        <version>${dependency-check-maven.version}</version>
-                        <executions>
-                            <execution>
-                                <goals>
-                                    <goal>aggregate</goal>
-                                </goals>
-                                <phase>none</phase>
-                            </execution>
-                        </executions>
-                    </plugin>
-                </plugins>
-            </build>
-        </profile>
-    </profiles>
-
-</project>
diff --git a/src/license-header.txt b/src/license-header.txt
new file mode 100644
index 0000000..60b675e
--- /dev/null
+++ b/src/license-header.txt
@@ -0,0 +1,16 @@
+Licensed to the Apache Software Foundation (ASF) under one
+or more contributor license agreements.  See the NOTICE file
+distributed with this work for additional information
+regarding copyright ownership.  The ASF licenses this file
+to you under the Apache License, Version 2.0 (the
+"License"); you may not use this file except in compliance
+with the License.  You may obtain a copy of the License at
+
+  http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing,
+software distributed under the License is distributed on an
+"AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+KIND, either express or implied.  See the License for the
+specific language governing permissions and limitations
+under the License.
diff --git a/tests/docker-images/latest-version-image/conf/presto/jvm.config b/tests/docker-images/latest-version-image/conf/trino/jvm.config
similarity index 100%
rename from tests/docker-images/latest-version-image/conf/presto/jvm.config
rename to tests/docker-images/latest-version-image/conf/trino/jvm.config
diff --git a/tests/docker-images/latest-version-image/conf/presto_worker.conf b/tests/docker-images/latest-version-image/conf/trino_worker.conf
similarity index 100%
rename from tests/docker-images/latest-version-image/conf/presto_worker.conf
rename to tests/docker-images/latest-version-image/conf/trino_worker.conf
diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/PrestoWorkerContainer.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/TrinoWorkerContainer.java
similarity index 100%
rename from tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/PrestoWorkerContainer.java
rename to tests/integration/src/test/java/org/apache/pulsar/tests/integration/containers/TrinoWorkerContainer.java
diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/Stock.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/Stock.java
similarity index 100%
rename from tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/Stock.java
rename to tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/Stock.java
diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/StockMsg.proto b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/StockMsg.proto
similarity index 100%
rename from tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/StockMsg.proto
rename to tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/StockMsg.proto
diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/StockProtoMessage.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/StockProtoMessage.java
similarity index 100%
rename from tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/StockProtoMessage.java
rename to tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/StockProtoMessage.java
diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/TestBasicPresto.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/TestBasicPresto.java
similarity index 100%
rename from tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/TestBasicPresto.java
rename to tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/TestBasicPresto.java
diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/TestPrestoQueryTieredStorage.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/TestPrestoQueryTieredStorage.java
similarity index 100%
rename from tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/TestPrestoQueryTieredStorage.java
rename to tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/TestPrestoQueryTieredStorage.java
diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/TestPulsarSQLAuth.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/TestPulsarSQLAuth.java
similarity index 100%
rename from tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/TestPulsarSQLAuth.java
rename to tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/TestPulsarSQLAuth.java
diff --git a/tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/TestPulsarSQLBase.java b/tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/TestPulsarSQLBase.java
similarity index 100%
rename from tests/integration/src/test/java/org/apache/pulsar/tests/integration/presto/TestPulsarSQLBase.java
rename to tests/integration/src/test/java/org/apache/pulsar/tests/integration/trino/TestPulsarSQLBase.java
diff --git a/tests/integration/src/test/resources/presto-coordinator-config.properties b/tests/integration/src/test/resources/trino-coordinator-config.properties
similarity index 100%
rename from tests/integration/src/test/resources/presto-coordinator-config.properties
rename to tests/integration/src/test/resources/trino-coordinator-config.properties
diff --git a/tests/integration/src/test/resources/presto-follow-worker-config.properties b/tests/integration/src/test/resources/trino-follow-worker-config.properties
similarity index 100%
rename from tests/integration/src/test/resources/presto-follow-worker-config.properties
rename to tests/integration/src/test/resources/trino-follow-worker-config.properties
diff --git a/pulsar-sql/presto-distribution/LICENSE b/trino-distribution/LICENSE
similarity index 100%
rename from pulsar-sql/presto-distribution/LICENSE
rename to trino-distribution/LICENSE
diff --git a/pulsar-sql/presto-distribution/pom.xml b/trino-distribution/pom.xml
similarity index 66%
rename from pulsar-sql/presto-distribution/pom.xml
rename to trino-distribution/pom.xml
index e327149..fc24a1b 100644
--- a/pulsar-sql/presto-distribution/pom.xml
+++ b/trino-distribution/pom.xml
@@ -21,26 +21,40 @@
 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
-
   <parent>
-    <groupId>org.apache.pulsar</groupId>
-    <artifactId>pulsar-sql</artifactId>
-    <version>3.0.8-SNAPSHOT</version>
+    <groupId>org.apache</groupId>
+    <artifactId>apache</artifactId>
+    <version>29</version>
   </parent>
 
-  <artifactId>pulsar-presto-distribution</artifactId>
-  <name>Pulsar SQL :: Pulsar Presto Distribution</name>
+  <groupId>org.apache.pulsar</groupId>
+  <artifactId>trino-pulsar-distribution</artifactId>
+  <name>Pulsar SQL :: Pulsar Trino Distribution</name>
+  <version>4.1.0-SNAPSHOT</version>
 
   <properties>
     <skipBuildDistribution>false</skipBuildDistribution>
     <jersey.version>2.42</jersey.version>
     <objenesis.version>2.6</objenesis.version>
     <objectsize.version>0.0.12</objectsize.version>
-    <maven.version>3.0.5</maven.version>
+    <maven.version>3.9.9</maven.version>
     <guava.version>32.1.1-jre</guava.version>
     <asynchttpclient.version>2.12.1</asynchttpclient.version>
     <errorprone.version>2.5.1</errorprone.version>
     <javax.servlet-api>4.0.1</javax.servlet-api>
+    <trino.version>461</trino.version>
+    <airlift.version>273</airlift.version>
+    <jackson.version>2.18.0</jackson.version>
+    <maven-assembly-plugin.version>3.7.1</maven-assembly-plugin.version>
+    <license-maven-plugin.version>4.6</license-maven-plugin.version>
+    <jetty.version>9.4.56.v20240826</jetty.version>
+    <guice.version>4.2.0</guice.version>
+    <!-- Launcher properties -->
+    <main-class>io.trino.server.TrinoServer</main-class>
+    <process-name>${project.artifactId}</process-name>
+    <!--fix Security Vulnerabilities-->
+    <!--https://www.cvedetails.com/vulnerability-list/vendor_id-15866/product_id-42991/Fasterxml-Jackson-databind.html-->
+    <jackson.databind.version>2.18.0</jackson.databind.version>
   </properties>
 
   <dependencies>
@@ -49,35 +63,40 @@
       <artifactId>jersey-common</artifactId>
       <version>${jersey.version}</version>
     </dependency>
+
     <dependency>
-      <groupId>org.glassfish.jersey.core</groupId>
-      <artifactId>jersey-server</artifactId>
+      <groupId>org.glassfish.jersey.containers</groupId>
+      <artifactId>jersey-container-servlet-core</artifactId>
       <version>${jersey.version}</version>
     </dependency>
+
     <dependency>
-      <groupId>org.glassfish.jersey.containers</groupId>
-      <artifactId>jersey-container-servlet-core</artifactId>
+      <groupId>org.glassfish.jersey.core</groupId>
+      <artifactId>jersey-client</artifactId>
       <version>${jersey.version}</version>
     </dependency>
+
     <dependency>
-      <groupId>org.glassfish.jersey.containers</groupId>
-      <artifactId>jersey-container-servlet</artifactId>
+      <groupId>org.glassfish.jersey.core</groupId>
+      <artifactId>jersey-server</artifactId>
       <version>${jersey.version}</version>
     </dependency>
+
     <dependency>
       <groupId>org.glassfish.jersey.inject</groupId>
       <artifactId>jersey-hk2</artifactId>
       <version>${jersey.version}</version>
     </dependency>
+
     <dependency>
-      <groupId>org.glassfish.jersey.core</groupId>
-      <artifactId>jersey-client</artifactId>
+      <groupId>org.glassfish.jersey.containers</groupId>
+      <artifactId>jersey-container-servlet</artifactId>
       <version>${jersey.version}</version>
     </dependency>
 
     <dependency>
       <groupId>io.trino</groupId>
-      <artifactId>trino-server-main</artifactId>
+      <artifactId>trino-main</artifactId>
       <version>${trino.version}</version>
       <exclusions>
         <!-- exclude openjdk because of GPL license -->
@@ -93,14 +112,6 @@
           <groupId>javax.activation</groupId>
           <artifactId>activation</artifactId>
         </exclusion>
-        <exclusion>
-          <groupId>com.google.inject.extensions</groupId>
-          <artifactId>guice-multibindings</artifactId>
-        </exclusion>
-        <exclusion>
-          <groupId>org.apache.logging.log4j</groupId>
-          <artifactId>log4j-to-slf4j</artifactId>
-        </exclusion>
       </exclusions>
     </dependency>
 
@@ -126,6 +137,14 @@
       <classifier>properties</classifier>
     </dependency>
 
+    <dependency>
+      <groupId>${project.groupId}</groupId>
+      <artifactId>trino-pulsar</artifactId>
+      <version>${project.version}</version>
+      <type>tar.gz</type>
+      <scope>provided</scope>
+    </dependency>
+
     <dependency>
       <groupId>org.objenesis</groupId>
       <artifactId>objenesis</artifactId>
@@ -136,12 +155,13 @@
       <groupId>com.twitter.common</groupId>
       <artifactId>objectsize</artifactId>
       <version>${objectsize.version}</version>
-      <exclusions>
-        <exclusion>
-          <artifactId>jsr305</artifactId>
-          <groupId>com.google.code.findbugs</groupId>
-        </exclusion>
-      </exclusions>
+    </dependency>
+
+    <!-- make sure guice is set to the correct version -->
+    <dependency>
+      <groupId>com.google.inject.extensions</groupId>
+      <artifactId>guice-multibindings</artifactId>
+      <version>${guice.version}</version>
     </dependency>
 
     <!-- jackson dependencies -->
@@ -149,46 +169,55 @@
     <dependency>
       <groupId>com.fasterxml.jackson.core</groupId>
       <artifactId>jackson-core</artifactId>
+      <version>${jackson.version}</version>
     </dependency>
 
     <dependency>
       <groupId>com.fasterxml.jackson.core</groupId>
       <artifactId>jackson-databind</artifactId>
+      <version>${jackson.databind.version}</version>
     </dependency>
 
     <dependency>
       <groupId>com.fasterxml.jackson.core</groupId>
       <artifactId>jackson-annotations</artifactId>
+      <version>${jackson.version}</version>
     </dependency>
 
     <dependency>
       <groupId>com.fasterxml.jackson.datatype</groupId>
       <artifactId>jackson-datatype-joda</artifactId>
+      <version>${jackson.version}</version>
     </dependency>
 
     <dependency>
       <groupId>com.fasterxml.jackson.dataformat</groupId>
       <artifactId>jackson-dataformat-yaml</artifactId>
+      <version>${jackson.version}</version>
     </dependency>
 
     <dependency>
       <groupId>com.fasterxml.jackson.datatype</groupId>
       <artifactId>jackson-datatype-guava</artifactId>
+      <version>${jackson.version}</version>
     </dependency>
 
     <dependency>
       <groupId>com.fasterxml.jackson.datatype</groupId>
       <artifactId>jackson-datatype-jdk8</artifactId>
+      <version>${jackson.version}</version>
     </dependency>
 
     <dependency>
       <groupId>com.fasterxml.jackson.datatype</groupId>
       <artifactId>jackson-datatype-jsr310</artifactId>
+      <version>${jackson.version}</version>
     </dependency>
 
     <dependency>
       <groupId>com.fasterxml.jackson.dataformat</groupId>
       <artifactId>jackson-dataformat-smile</artifactId>
+      <version>${jackson.version}</version>
     </dependency>
 
   </dependencies>
@@ -203,7 +232,7 @@
       <dependency>
         <groupId>io.netty</groupId>
         <artifactId>netty</artifactId>
-        <version>3.10.6.Final</version>
+        <version>4.1.113.Final</version>
       </dependency>
 
       <dependency>
@@ -236,63 +265,6 @@
         <artifactId>guava</artifactId>
         <version>${guava.version}</version>
       </dependency>
-      <dependency>
-        <groupId>com.google.errorprone</groupId>
-        <artifactId>error_prone_annotations</artifactId>
-        <version>${errorprone.version}</version>
-      </dependency>
-      <dependency>
-        <groupId>com.fasterxml.jackson</groupId>
-        <artifactId>jackson-bom</artifactId>
-        <version>${jackson.version}</version>
-        <type>pom</type>
-        <scope>import</scope>
-      </dependency>
-      <dependency>
-        <groupId>org.eclipse.jetty</groupId>
-        <artifactId>jetty-http</artifactId>
-        <version>${jetty.version}</version>
-      </dependency>
-      <dependency>
-        <groupId>org.eclipse.jetty</groupId>
-        <artifactId>jetty-client</artifactId>
-        <version>${jetty.version}</version>
-      </dependency>
-      <dependency>
-        <groupId>org.eclipse.jetty</groupId>
-        <artifactId>jetty-io</artifactId>
-        <version>${jetty.version}</version>
-      </dependency>
-      <dependency>
-        <groupId>org.eclipse.jetty</groupId>
-        <artifactId>jetty-security</artifactId>
-        <version>${jetty.version}</version>
-      </dependency>
-      <dependency>
-        <groupId>org.eclipse.jetty</groupId>
-        <artifactId>jetty-jmx</artifactId>
-        <version>${jetty.version}</version>
-      </dependency>
-      <dependency>
-        <groupId>org.eclipse.jetty.http2</groupId>
-        <artifactId>http2-client</artifactId>
-        <version>${jetty.version}</version>
-      </dependency>
-      <dependency>
-        <groupId>org.eclipse.jetty.http2</groupId>
-        <artifactId>http2-http-client-transport</artifactId>
-        <version>${jetty.version}</version>
-      </dependency>
-      <dependency>
-        <groupId>org.eclipse.jetty.http2</groupId>
-        <artifactId>http2-server</artifactId>
-        <version>${jetty.version}</version>
-      </dependency>
-      <dependency>
-        <groupId>javax.servlet</groupId>
-        <artifactId>javax.servlet-api</artifactId>
-        <version>${javax.servlet-api}</version>
-      </dependency>
     </dependencies>
   </dependencyManagement>
 
@@ -300,16 +272,11 @@
     <plugins>
       <plugin>
         <groupId>org.apache.maven.plugins</groupId>
-        <artifactId>maven-deploy-plugin</artifactId>
-        <configuration>
-          <skip>${skipBuildDistribution}</skip>
-        </configuration>
+        <artifactId>maven-install-plugin</artifactId>
       </plugin>
-
       <plugin>
-        <groupId>org.apache.maven.plugins</groupId>
         <artifactId>maven-assembly-plugin</artifactId>
-        <version>${maven-assembly-plugin.version}</version>
+        <version>3.7.1</version>
         <configuration>
           <appendAssemblyId>false</appendAssemblyId>
           <attach>true</attach>
@@ -330,19 +297,48 @@
         </executions>
       </plugin>
 
+      <plugin>
+        <groupId>org.codehaus.mojo</groupId>
+        <artifactId>templating-maven-plugin</artifactId>
+        <version>3.0.0</version>
+        <executions>
+          <execution>
+            <id>filter-src</id>
+            <goals>
+              <goal>filter-sources</goal>
+            </goals>
+            <phase>package</phase>
+            <configuration>
+              <sourceDirectory>${project.build.directory}/${project.artifactId}/bin/</sourceDirectory>
+              <outputDirectory>${project.build.directory}/${project.artifactId}/bin/</outputDirectory>
+              <overwrite>true</overwrite>
+              <delimiters>
+                <delimiter>${*}</delimiter>
+              </delimiters>
+            </configuration>
+          </execution>
+        </executions>
+      </plugin>
       <plugin>
         <groupId>com.mycila</groupId>
         <artifactId>license-maven-plugin</artifactId>
-        <version>${license-maven-plugin.version}</version>
+        <version>4.6</version>
         <configuration>
-          <licenseSets>
-            <licenseSet>
-              <header>../../src/license-header.txt</header>
-            </licenseSet>
-          </licenseSets>
-          <mapping>
-            <java>SLASHSTAR_STYLE</java>
-          </mapping>
+          <header>../src/license-header.txt</header>
+        </configuration>
+      </plugin>
+      <plugin>
+        <artifactId>maven-compiler-plugin</artifactId>
+        <configuration>
+          <source>3.13.0</source>
+          <target>3.13.0</target>
+        </configuration>
+      </plugin>
+      <plugin>
+        <groupId>org.apache.maven.plugins</groupId>
+        <artifactId>maven-checkstyle-plugin</artifactId>
+        <configuration>
+          <skip>true</skip>
         </configuration>
       </plugin>
     </plugins>
@@ -350,35 +346,8 @@
       <extension>
         <groupId>org.apache.maven.wagon</groupId>
         <artifactId>wagon-ssh-external</artifactId>
-        <version>3.4.3</version>
+        <version>3.5.3</version>
       </extension>
     </extensions>
   </build>
-
-  <profiles>
-    <profile>
-      <id>skipBuildDistributionDisabled</id>
-      <activation>
-        <property>
-          <name>skipBuildDistribution</name>
-          <value>!true</value>
-        </property>
-      </activation>
-      <dependencies>
-        <dependency>
-          <groupId>${project.groupId}</groupId>
-          <artifactId>pulsar-presto-connector</artifactId>
-          <version>${project.version}</version>
-          <type>tar.gz</type>
-          <scope>provided</scope>
-          <exclusions>
-            <exclusion>
-              <groupId>*</groupId>
-              <artifactId>*</artifactId>
-            </exclusion>
-          </exclusions>
-        </dependency>
-      </dependencies>
-    </profile>
-  </profiles>
 </project>
diff --git a/pulsar-sql/presto-distribution/src/assembly/assembly.xml b/trino-distribution/src/assembly/assembly.xml
similarity index 100%
rename from pulsar-sql/presto-distribution/src/assembly/assembly.xml
rename to trino-distribution/src/assembly/assembly.xml
diff --git a/pulsar-sql/presto-distribution/src/main/java/org/openjdk/jol/info/ClassLayout.java b/trino-distribution/src/main/java/org/openjdk/jol/info/ClassLayout.java
similarity index 100%
rename from pulsar-sql/presto-distribution/src/main/java/org/openjdk/jol/info/ClassLayout.java
rename to trino-distribution/src/main/java/org/openjdk/jol/info/ClassLayout.java
diff --git a/pulsar-sql/presto-distribution/src/main/java/org/openjdk/jol/info/package-info.java b/trino-distribution/src/main/java/org/openjdk/jol/info/package-info.java
similarity index 100%
rename from pulsar-sql/presto-distribution/src/main/java/org/openjdk/jol/info/package-info.java
rename to trino-distribution/src/main/java/org/openjdk/jol/info/package-info.java
diff --git a/pulsar-sql/presto-distribution/src/main/resources/conf/catalog/pulsar.properties b/trino-distribution/src/main/resources/conf/catalog/pulsar.properties
similarity index 100%
rename from pulsar-sql/presto-distribution/src/main/resources/conf/catalog/pulsar.properties
rename to trino-distribution/src/main/resources/conf/catalog/pulsar.properties
diff --git a/pulsar-sql/presto-distribution/src/main/resources/conf/config.properties b/trino-distribution/src/main/resources/conf/config.properties
similarity index 100%
rename from pulsar-sql/presto-distribution/src/main/resources/conf/config.properties
rename to trino-distribution/src/main/resources/conf/config.properties
diff --git a/pulsar-sql/presto-distribution/src/main/resources/conf/jvm.config b/trino-distribution/src/main/resources/conf/jvm.config
similarity index 100%
rename from pulsar-sql/presto-distribution/src/main/resources/conf/jvm.config
rename to trino-distribution/src/main/resources/conf/jvm.config
diff --git a/pulsar-sql/presto-distribution/src/main/resources/conf/log.properties b/trino-distribution/src/main/resources/conf/log.properties
similarity index 100%
rename from pulsar-sql/presto-distribution/src/main/resources/conf/log.properties
rename to trino-distribution/src/main/resources/conf/log.properties
diff --git a/pulsar-sql/presto-distribution/src/main/resources/launcher.properties b/trino-distribution/src/main/resources/launcher.properties
similarity index 100%
rename from pulsar-sql/presto-distribution/src/main/resources/launcher.properties
rename to trino-distribution/src/main/resources/launcher.properties
diff --git a/pulsar-sql/presto-pulsar-plugin/pom.xml b/trino-pulsar-plugin/pom.xml
similarity index 88%
rename from pulsar-sql/presto-pulsar-plugin/pom.xml
rename to trino-pulsar-plugin/pom.xml
index 806399d..8b49e0f 100644
--- a/pulsar-sql/presto-pulsar-plugin/pom.xml
+++ b/trino-pulsar-plugin/pom.xml
@@ -25,24 +25,23 @@
     <parent>
         <groupId>org.apache.pulsar</groupId>
         <artifactId>pulsar-sql</artifactId>
-        <version>3.0.8-SNAPSHOT</version>
+        <version>4.1.0-SNAPSHOT</version>
     </parent>
 
-    <artifactId>pulsar-presto-connector</artifactId>
-    <name>Pulsar SQL :: Pulsar Presto Connector</name>
+    <artifactId>trino-pulsar-plugin</artifactId>
+    <name>Pulsar SQL :: Pulsar Trino Connector</name>
 
     <dependencies>
-
         <dependency>
             <groupId>${project.groupId}</groupId>
-            <artifactId>pulsar-presto-connector-original</artifactId>
+            <artifactId>trino-pulsar</artifactId>
             <version>${project.version}</version>
         </dependency>
 
         <dependency>
-            <groupId>${project.groupId}</groupId>
+            <groupId>org.apache.pulsar</groupId>
             <artifactId>bouncy-castle-bc</artifactId>
-            <version>${project.version}</version>
+            <version>4.0.0-preview.1</version>
             <classifier>pkg</classifier>
             <optional>true</optional>
         </dependency>
diff --git a/pulsar-sql/presto-pulsar-plugin/src/assembly/assembly.xml b/trino-pulsar-plugin/src/assembly/assembly.xml
similarity index 100%
rename from pulsar-sql/presto-pulsar-plugin/src/assembly/assembly.xml
rename to trino-pulsar-plugin/src/assembly/assembly.xml
diff --git a/pulsar-sql/presto-pulsar/pom.xml b/trino-pulsar/pom.xml
similarity index 89%
rename from pulsar-sql/presto-pulsar/pom.xml
rename to trino-pulsar/pom.xml
index 9699c39..49757ad 100644
--- a/pulsar-sql/presto-pulsar/pom.xml
+++ b/trino-pulsar/pom.xml
@@ -25,22 +25,34 @@
     <parent>
         <groupId>org.apache.pulsar</groupId>
         <artifactId>pulsar-sql</artifactId>
-        <version>3.0.8-SNAPSHOT</version>
+        <version>4.1.0-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>
     </parent>
 
-    <artifactId>pulsar-presto-connector-original</artifactId>
-    <description>Pulsar SQL - Pulsar Presto Connector</description>
-    <name>Pulsar SQL :: Pulsar Presto Connector Packaging</name>
+    <artifactId>trino-pulsar</artifactId>
+    <description>Pulsar SQL - Pulsar Trino Connector</description>
+    <name>Pulsar SQL :: Pulsar Trino Connector Packaging</name>
 
     <properties>
         <jctools.version>2.1.2</jctools.version>
         <dslJson.verson>1.8.4</dslJson.verson>
+        <avro.version>1.12.0</avro.version>
+        <joda.version>2.12.7</joda.version>
+        <trino.version>461</trino.version>
+        <airlift.version>273</airlift.version>
+        <pulsar.version>4.0.0-preview.1</pulsar.version>
+        <assertj-core.version>3.24.2</assertj-core.version>
+        <lombok.version>1.18.32</lombok.version>
+        <javax.annotation-api.version>1.3.2</javax.annotation-api.version>
+        <jsonwebtoken.version>0.11.1</jsonwebtoken.version>
+        <jetty.version>9.4.56.v20240826</jetty.version>
     </properties>
 
     <dependencies>
         <dependency>
             <groupId>io.airlift</groupId>
             <artifactId>bootstrap</artifactId>
+            <version>${airlift.version}</version>
             <exclusions>
                 <exclusion>
                     <groupId>org.apache.logging.log4j</groupId>
@@ -51,6 +63,7 @@
         <dependency>
             <groupId>io.airlift</groupId>
             <artifactId>json</artifactId>
+            <version>${airlift.version}</version>
         </dependency>
 
         <dependency>
@@ -62,13 +75,13 @@
         <dependency>
             <groupId>${project.groupId}</groupId>
             <artifactId>pulsar-client-admin-original</artifactId>
-            <version>${project.version}</version>
+            <version>${pulsar.version}</version>
         </dependency>
 
         <dependency>
             <groupId>${project.groupId}</groupId>
             <artifactId>managed-ledger</artifactId>
-            <version>${project.version}</version>
+            <version>${pulsar.version}</version>
         </dependency>
 
         <dependency>
@@ -139,14 +152,14 @@
         <dependency>
           <groupId>org.apache.pulsar</groupId>
           <artifactId>pulsar-broker</artifactId>
-          <version>${project.version}</version>
+          <version>${pulsar.version}</version>
           <scope>test</scope>
         </dependency>
 
         <dependency>
           <groupId>org.apache.pulsar</groupId>
           <artifactId>testmocks</artifactId>
-          <version>${project.version}</version>
+          <version>${pulsar.version}</version>
           <scope>test</scope>
         </dependency>
 
@@ -166,7 +179,7 @@
                 <artifactId>maven-shade-plugin</artifactId>
                 <executions>
                     <execution>
-                        <phase>${shadePluginPhase}</phase>
+                        <phase>none</phase>
                         <goals>
                             <goal>shade</goal>
                         </goals>
@@ -250,7 +263,7 @@
                 <dependency>
                     <groupId>${project.groupId}</groupId>
                     <artifactId>pulsar-broker</artifactId>
-                    <version>${project.version}</version>
+                    <version>${pulsar.version}</version>
                     <type>test-jar</type>
                     <scope>test</scope>
                 </dependency>
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarAuth.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarAuth.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarAuth.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarAuth.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnHandle.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnHandle.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnHandle.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnHandle.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnMetadata.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnMetadata.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnMetadata.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnMetadata.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnector.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnector.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnector.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnector.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorConfig.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorConfig.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorConfig.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorConfig.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorFactory.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorFactory.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorFactory.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorFactory.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorId.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorId.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorId.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorId.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorMetricsTracker.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorMetricsTracker.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorMetricsTracker.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorMetricsTracker.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorModule.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorModule.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorModule.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorModule.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorUtils.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorUtils.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorUtils.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorUtils.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarDispatchingRowDecoderFactory.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarDispatchingRowDecoderFactory.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarDispatchingRowDecoderFactory.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarDispatchingRowDecoderFactory.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarFieldValueProviders.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarFieldValueProviders.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarFieldValueProviders.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarFieldValueProviders.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarHandleResolver.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarHandleResolver.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarHandleResolver.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarHandleResolver.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarInternalColumn.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarInternalColumn.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarInternalColumn.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarInternalColumn.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarPlugin.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarPlugin.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarPlugin.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarPlugin.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordSet.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordSet.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordSet.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordSet.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordSetProvider.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordSetProvider.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordSetProvider.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordSetProvider.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRowDecoder.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRowDecoder.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRowDecoder.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRowDecoder.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRowDecoderFactory.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRowDecoderFactory.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRowDecoderFactory.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRowDecoderFactory.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplit.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplit.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplit.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplit.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTableHandle.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTableHandle.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTableHandle.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTableHandle.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTableLayoutHandle.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTableLayoutHandle.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTableLayoutHandle.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTableLayoutHandle.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTopicDescription.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTopicDescription.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTopicDescription.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTopicDescription.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTransactionHandle.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTransactionHandle.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTransactionHandle.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTransactionHandle.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroColumnDecoder.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroColumnDecoder.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroColumnDecoder.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroColumnDecoder.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroRowDecoder.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroRowDecoder.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroRowDecoder.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroRowDecoder.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroRowDecoderFactory.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroRowDecoderFactory.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroRowDecoderFactory.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/PulsarAvroRowDecoderFactory.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/package-info.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/package-info.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/package-info.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/avro/package-info.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonFieldDecoder.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonFieldDecoder.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonFieldDecoder.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonFieldDecoder.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonRowDecoder.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonRowDecoder.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonRowDecoder.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonRowDecoder.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonRowDecoderFactory.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonRowDecoderFactory.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonRowDecoderFactory.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/PulsarJsonRowDecoderFactory.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/package-info.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/package-info.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/package-info.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/json/package-info.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/PulsarPrimitiveRowDecoder.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/PulsarPrimitiveRowDecoder.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/PulsarPrimitiveRowDecoder.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/PulsarPrimitiveRowDecoder.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/PulsarPrimitiveRowDecoderFactory.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/PulsarPrimitiveRowDecoderFactory.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/PulsarPrimitiveRowDecoderFactory.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/PulsarPrimitiveRowDecoderFactory.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/package-info.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/package-info.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/package-info.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/primitive/package-info.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeColumnDecoder.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeColumnDecoder.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeColumnDecoder.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeColumnDecoder.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeRowDecoder.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeRowDecoder.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeRowDecoder.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeRowDecoder.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeRowDecoderFactory.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeRowDecoderFactory.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeRowDecoderFactory.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/PulsarProtobufNativeRowDecoderFactory.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/package-info.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/package-info.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/package-info.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/decoder/protobufnative/package-info.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/package-info.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/package-info.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/package-info.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/package-info.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/CacheSizeAllocator.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/CacheSizeAllocator.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/CacheSizeAllocator.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/CacheSizeAllocator.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/NoStrictCacheSizeAllocator.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/NoStrictCacheSizeAllocator.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/NoStrictCacheSizeAllocator.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/NoStrictCacheSizeAllocator.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/NullCacheSizeAllocator.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/NullCacheSizeAllocator.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/NullCacheSizeAllocator.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/NullCacheSizeAllocator.java
diff --git a/pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/package-info.java b/trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/package-info.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/package-info.java
rename to trino-pulsar/src/main/java/org/apache/pulsar/sql/presto/util/package-info.java
diff --git a/pulsar-sql/presto-pulsar/src/main/resources/META-INF/services/io.trino.spi.Plugin b/trino-pulsar/src/main/resources/META-INF/services/io.trino.spi.Plugin
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/main/resources/META-INF/services/io.trino.spi.Plugin
rename to trino-pulsar/src/main/resources/META-INF/services/io.trino.spi.Plugin
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestCacheSizeAllocator.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestCacheSizeAllocator.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestCacheSizeAllocator.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestCacheSizeAllocator.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestNoStrictCacheSizeAllocator.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestNoStrictCacheSizeAllocator.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestNoStrictCacheSizeAllocator.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestNoStrictCacheSizeAllocator.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarAuth.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarAuth.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarAuth.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarAuth.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnector.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnector.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnector.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnector.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnectorConfig.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnectorConfig.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnectorConfig.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnectorConfig.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarMetadata.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarMetadata.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarMetadata.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarMetadata.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarRecordCursor.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarRecordCursor.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarRecordCursor.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarRecordCursor.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarSplitManager.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarSplitManager.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarSplitManager.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarSplitManager.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestReadChunkedMessages.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestReadChunkedMessages.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestReadChunkedMessages.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestReadChunkedMessages.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/AbstractDecoderTester.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/AbstractDecoderTester.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/AbstractDecoderTester.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/AbstractDecoderTester.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/DecoderTestMessage.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/DecoderTestMessage.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/DecoderTestMessage.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/DecoderTestMessage.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/DecoderTestUtil.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/DecoderTestUtil.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/DecoderTestUtil.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/DecoderTestUtil.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/AvroDecoderTestUtil.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/AvroDecoderTestUtil.java
similarity index 98%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/AvroDecoderTestUtil.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/AvroDecoderTestUtil.java
index a32a8d4..79f9051 100644
--- a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/AvroDecoderTestUtil.java
+++ b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/AvroDecoderTestUtil.java
@@ -16,14 +16,14 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.pulsar.sql.presto.decoder.avro;
+package org.apache.pulsar.sql.trino.decoder.avro;
 
 import io.trino.spi.block.Block;
 import io.trino.spi.type.*;
 import org.apache.avro.generic.GenericEnumSymbol;
 import org.apache.avro.generic.GenericFixed;
 import org.apache.avro.generic.GenericRecord;
-import org.apache.pulsar.sql.presto.decoder.DecoderTestUtil;
+import org.apache.pulsar.sql.trino.decoder.DecoderTestUtil;
 
 import java.nio.ByteBuffer;
 import java.util.List;
@@ -184,7 +184,7 @@ public void checkRowValues(Block block, Type type, Object value) {
         GenericRecord record = (GenericRecord) value;
         RowType rowType = (RowType) type;
         assertEquals(record.getSchema().getFields().size(), rowType.getFields().size(), "Avro field size mismatch");
-        assertEquals(block.getPositionCount(), rowType.getFields().size(), "Presto type field size mismatch");
+        assertEquals(block.getPositionCount(), rowType.getFields().size(), "trino type field size mismatch");
         for (int fieldIndex = 0; fieldIndex < rowType.getFields().size(); fieldIndex++) {
             RowType.Field rowField = rowType.getFields().get(fieldIndex);
             Object expectedValue = record.get(rowField.getName().get());
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/TestAvroDecoder.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/TestAvroDecoder.java
similarity index 99%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/TestAvroDecoder.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/TestAvroDecoder.java
index 5f9df96..43e00eb 100644
--- a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/TestAvroDecoder.java
+++ b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/avro/TestAvroDecoder.java
@@ -16,7 +16,7 @@
  * specific language governing permissions and limitations
  * under the License.
  */
-package org.apache.pulsar.sql.presto.decoder.avro;
+package org.apache.pulsar.sql.trino.decoder.avro;
 
 import static io.trino.spi.type.BigintType.BIGINT;
 import static io.trino.spi.type.BooleanType.BOOLEAN;
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/json/JsonDecoderTestUtil.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/json/JsonDecoderTestUtil.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/json/JsonDecoderTestUtil.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/json/JsonDecoderTestUtil.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/json/TestJsonDecoder.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/json/TestJsonDecoder.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/json/TestJsonDecoder.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/json/TestJsonDecoder.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/primitive/PrimitiveDecoderTestUtil.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/primitive/PrimitiveDecoderTestUtil.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/primitive/PrimitiveDecoderTestUtil.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/primitive/PrimitiveDecoderTestUtil.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/primitive/TestPrimitiveDecoder.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/primitive/TestPrimitiveDecoder.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/primitive/TestPrimitiveDecoder.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/primitive/TestPrimitiveDecoder.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/ProtobufNativeDecoderTestUtil.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/ProtobufNativeDecoderTestUtil.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/ProtobufNativeDecoderTestUtil.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/ProtobufNativeDecoderTestUtil.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestMsg.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestMsg.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestMsg.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestMsg.java
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestMsg.proto b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestMsg.proto
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestMsg.proto
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestMsg.proto
diff --git a/pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestProtobufNativeDecoder.java b/trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestProtobufNativeDecoder.java
similarity index 100%
rename from pulsar-sql/presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestProtobufNativeDecoder.java
rename to trino-pulsar/src/test/java/org/apache/pulsar/sql/presto/decoder/protobufnative/TestProtobufNativeDecoder.java