You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by si...@apache.org on 2020/11/11 21:52:02 UTC
[pulsar-presto] branch master updated (b11a51c -> 6e75f1f)
This is an automated email from the ASF dual-hosted git repository.
sijie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar-presto.git.
discard b11a51c Initialize pulsar-presto project
new 43b3de9 PIP-19: Initial implementation of Pulsar SQL (#2265)
new ea1d856 Fixed refcounting when processing entries from sql (#2316)
new 4bb4108 allow predicates concerning publish time to push down to pulsar (#2414)
new 63ead3f improve error message handling (#2435)
new d284550 Package Presto with Pulsar for SQL integration (#2428)
new 36c86f4 better way to estimate object size for sql (#2528)
new 553ce73 Downgrading ZK to stable version 3.4.13 (#2473)
new 3045254 support nested fields in Pulsar presto connector (#2515)
new 19b7bfe set correct guice version to prevent dependency inject errors in docker container (#2534)
new 5bea465 [build] Fix maven deploy failure (#2565)
new efa17c7 optimizing throughput in Pulsar Presto connector (#2564)
new 7dc7b0b Renamed 2.2.0-incubating-SNAPSHOT into 2.2.0-SNAPSHOT in poms (#2625)
new 8ebde31 add wagon-ssh plugin to modules not inherit pulsar parent (#2696)
new dc92e60 adding metrics to presto pulsar connector (#2631)
new c2b0cdf Removed shading relocations for Circe-checksum and lz4 libraries (#2191)
new b42017f Avoid shading netty in managed-ledger-shaded (#2741)
new 81192ec Bumped version to 2.3.0-SNAPSHOT (#2765)
new 0585b78 Added script to change the project version in 1 command (#2772)
new 942acbd Fixed shading of Netty (#2783)
new 3929a2c Function Serverside validation Part 2 (#2752)
new 4ebd902 Export Jetty stats to Prometheus (#2804)
new dd97a65 Bump jetty to v9.4.12 (#2811)
new c7da92d Upgrade commons-collections for Security Vulnerabilities[CVE-2015-7501] (#2886)
new d687eb1 Upgrade jackson version to 2.9.7 (#2884)
new 1071d9c Remove functions-util dependency from pulsar-client-admin (#2917)
new 18e6997 reverting jackson version bump for sql (#2978)
new 2f6cd56 adding windowed metrics for functions (#3021)
new 5acb127 Fixes for Java 11 (#3006)
new 54bfe56 Few optimizations for pulsar sql (#3128)
new 69ca22f Use BK v2 protocol from Presto connector (#3135)
new b6eebfd more optimizations for sql (#3139)
new 9ecb464 optimizing json deserialization in sql (#3144)
new d0cf8cb Use raw message when manually parsing messages from topic storage (#3146)
new aa48f5b improve avro schema deserialization by reusing binary decoder (#3158)
new 35c6fbe cleaning up pom for pulsar-client-schema (#3175)
new 323854b remove pulsar-client-schema (#3184)
new 7e7a29f Get information_schema for pulsar connector to work (#3195)
new 7610ddb enable java enums to be queried in sql (#3202)
new eddec09 Issue 3247: Build error on linux if userid is an huge number (#3248)
new cafa5ac fix dep to make build compatible with jdk11 (#3357)
new 9c5c4d1 Added support for ZSTD compression (#3159)
new a6d0107 Upgrade BouncyCastle to 1.60 (#3495)
new 679d22e Upgrade AsyncHTTP client to 2.7.0 (#3509)
new eb36542 Add configuration to enabled BK sticky reads (#3569)
new 87338f8 Bumped version to 2.4.0-SNAPSHOT (#3604)
new 9e4a561 revise the schema default type not null (#3752)
new e833a65 Upgrade third party libraries with security vulnerabilities (#3938)
new 6bf6916 Add tiered storage support for Pulsar SQL (#4045)
new edf5687 Update bookkeeper ver to 4.9.1 (#4149)
new 29deb11 [WIP] PIP-36: Support set message size in broker.conf (#4247)
new 0bf4ec0 Upgrade to BookKeeper 4.9.2 (#4288)
new 46d865f [schema] Fix joda dependency issue. (#4207)
new 532b679 Use same activation dependency in pulsar-client-admin and pulsar-client (#4256)
new 886689d rest: add swagger doc for tenants (#4421)
new 64079bf Include pulsar-client-api in shaded client artifacts (#4445)
new a467728 Bumped version to 2.5.0-SNAPSHOT (#4581)
new 8647f14 Cleanup tests in the presto module (#4683)
new d40f633 Upgrade to Mockito 2.x (#4671)
new c5fc4c5 Change type of publish_time to timestamp (#4757)
new 1b3c0d3 Allow to configure ack-timeout tick time (#4760)
new 3bfabfd Convert anonymous classes to lambda (#4703)
new 3755803 Add options to rewrite namespace delimiter for pulsar sql. (#4749)
new a8c98be Pulsar SQL supports pulsar's primitive schema (#4728)
new 06de005 add basic authentication capabilities to Pulsar SQL (#4779)
new 6366cbf Test cleanup and simplification (#4799)
new 4707819 Reuse ManagedLedgerFactory instances across SQL queries (#4813)
new 7e5c06a Enforce checkstyle in the pulsar sql module (#4882)
new 6235734 [pulsar-sql] Make partition as internal column (#4888)
new 762f8fa [pulsar-sql] Handle schema not found (#4890)
new f1d0358 Upgrade jackson-databind (#5011)
new 1023b6b Removed managed-ledger-shaded artifact (#4200)
new f8c4c43 Upgrade dependencies for security fixes (#5232)
new c6f2727 [zookeeper] bump zookeeper to version 3.5.6 (#5043)
new 0bcc432 Fix license file in the distribution package (#5578)
new 076bd7f Upgrade bk version to 4.10.0 (#5607)
new 95ca23f [PIP-38] Support batch receive in java client. (#4621)
new ba62b93 [Pulsar-sql]Using pulsar SQL query messages will appear `NoSuchLedger` when zk root directory changed (#5001)
new b60d047 [transaction-coordinator] Implementation of transaction coordinator client. (#5680)
new c31bfc8 Bump version to 2.6.0 (#5820)
new 81463cd [pulsar-sql]Expose configurations of managed ledger and bookkeeper client. (#5702)
new 5ac8914 Added catch for NoClassDefFoundError wherever there was a ClassNotFoundException (#5870)
new 4638afb Upgrade Avro to 1.9.1 (#5938)
new 0d14644 Pin the netty-transport-native-epoll to avoid conflicts (#6194)
new 295c987 Namespace level offloader (#6183)
new 5b57ced PIP-45: Switch ManagedLedger to use MetadataStore interface (#5358)
new 1961688 Upgrade ZooKeeper to 3.5.7 (#6329)
new abb4701 KeyValue schema support for pulsar sql (#6325)
new 543c66b Bump netty version to 4.1.45.Final (#6424)
new 2af3d83 Remove duplicated test libraries in POM dependencies (#6430)
new 98fb92f [minor]Reduce redundancy (#6611)
new 463f5bb Support BouncyCastle FIPS provider (#6588)
new 0482a90 Bump netty version to 4.1.48.Final (#6746)
new 0195203 Pulsar SQL Support Avro Schema `ByteBuffer` Type (#6925)
new ab5e6e3 Make Nar Extraction Directory configurable (#6933)
new e231a5e Support multiple Avro schema version in Pulsar SQL (#4847)
new addfe11 Fix presto SQL does not start prometheus service by default (#7030)
new dfae5fc Add pulsar SQL woker metrics to repo (#7031)
new aaad08f Remove double @Test annotations (#7063)
new 6e491d9 update asynchttpclient verison (#7087)
new 6cedca8 [Pulsar SQL] Fix pulsar sql use multi zk address failed (#6947)
new 1b4f860 Use pure-java Air-Compressor instead of JNI based libraries (#5390)
new c22c268 [Issue 7202] Upgrade commons-lang3 version to 3.6 (#7203)
new 2e0905a Bumped version to 2.7.0-SNAPSHOT (#7233)
new edfee63 Upgrade Presto version to 332 (#7194)
new cf0031f Update Jetty to 9.4.29 (#7235)
new 54e16bf Update Jackson to 2.11.1 and ensure all dependencies are pinned (#7519)
new 2bc17f1 #5922 - Update poms to use project.groupId instead of org.apache.pulsar where applicable (#7548)
new 4f8adec Update Jersey to 2.31 (#7515)
new 1ca1edd Avoid dependency on Apache HTTP client for TLS hostname verifier (#7612) (#7664)
new 1bbc283 [Pulsar SQL] Make Pulsar SQL get correct offload configurations (#7701)
new 6de83d1 Fix security vulnerabilities of Pulsar (#7801)
new 7fcf44b [Pulsar SQL] Fix Pulsar SQL CI test (#7898)
new 7bb7e4b Upgrade jetty-util version to 9.4.31 (#8035)
new 455a6d7 Fix protobuf version to 3.11.4 (#8028)
new 03c5d13 Replace com.ning.asynchttpclient with org.asynchttpclient (#8099)
new 79aae75 Upgrade Jcommander to 1.78 (#8206)
new f2ad1eb Remove bouncy castle shaded module to avoid bring error of verifySingleJar (#7453)
new ad0c0d4 Sync license-maven-plugin version (#8367)
new c84a8a2 [Offload] Make the field name in `OffloadPolicies` match with config file (#8310)
new c7f30b7 Allow building Apache Pulsar on JDK15+ - upgrade Maven Assembly Plugin (#8360)
new 2116553 Upgrade Apache BookKeeper Client to 4.11.1 (#8270)
new ae4490c Upgrade jetty to 9.4.33.v20201020 (#8413)
new 5d6471c [Bouncy Castle] include bc into pulsar-client fix docs (#8491)
new ed2f50a PIP-19: Initial implementation of Pulsar SQL (#2265)
new 72210bb Fixed refcounting when processing entries from sql (#2316)
new 0b2f2f3 allow predicates concerning publish time to push down to pulsar (#2414)
new 7865142 improve error message handling (#2435)
new a83298e Package Presto with Pulsar for SQL integration (#2428)
new bec5e8c better way to estimate object size for sql (#2528)
new e06111a Downgrading ZK to stable version 3.4.13 (#2473)
new f366318 support nested fields in Pulsar presto connector (#2515)
new 83bc037 set correct guice version to prevent dependency inject errors in docker container (#2534)
new 0b99e96 [build] Fix maven deploy failure (#2565)
new 135b0ea optimizing throughput in Pulsar Presto connector (#2564)
new c2d9bf2 Renamed 2.2.0-incubating-SNAPSHOT into 2.2.0-SNAPSHOT in poms (#2625)
new eb34281 add wagon-ssh plugin to modules not inherit pulsar parent (#2696)
new 81fdcc1 adding metrics to presto pulsar connector (#2631)
new 8d40062 Removed shading relocations for Circe-checksum and lz4 libraries (#2191)
new 691fe80 Avoid shading netty in managed-ledger-shaded (#2741)
new 307b398 Bumped version to 2.3.0-SNAPSHOT (#2765)
new ddaa523 Added script to change the project version in 1 command (#2772)
new 61dcad0 Fixed shading of Netty (#2783)
new 8ceb1a7 Function Serverside validation Part 2 (#2752)
new a59fad1 Export Jetty stats to Prometheus (#2804)
new c203e7a Bump jetty to v9.4.12 (#2811)
new d1e98bf Upgrade commons-collections for Security Vulnerabilities[CVE-2015-7501] (#2886)
new a05304a Upgrade jackson version to 2.9.7 (#2884)
new 5c7f414 Remove functions-util dependency from pulsar-client-admin (#2917)
new d2f8cc9 reverting jackson version bump for sql (#2978)
new 988c954 adding windowed metrics for functions (#3021)
new 3e31f72 Fixes for Java 11 (#3006)
new 0580baa Few optimizations for pulsar sql (#3128)
new 54c43f2 Use BK v2 protocol from Presto connector (#3135)
new 228918e more optimizations for sql (#3139)
new 77a340b optimizing json deserialization in sql (#3144)
new 71fa5f1 Use raw message when manually parsing messages from topic storage (#3146)
new fbc726e improve avro schema deserialization by reusing binary decoder (#3158)
new ecf7ac3 cleaning up pom for pulsar-client-schema (#3175)
new 8aeb6ab remove pulsar-client-schema (#3184)
new 64bff34 Get information_schema for pulsar connector to work (#3195)
new b710798 enable java enums to be queried in sql (#3202)
new 1a1765b Issue 3247: Build error on linux if userid is an huge number (#3248)
new 16bbeed fix dep to make build compatible with jdk11 (#3357)
new 988a4ba Added support for ZSTD compression (#3159)
new 2485250 Upgrade BouncyCastle to 1.60 (#3495)
new 7fd383d Upgrade AsyncHTTP client to 2.7.0 (#3509)
new 8899f3a Add configuration to enabled BK sticky reads (#3569)
new 5f04ad5 Bumped version to 2.4.0-SNAPSHOT (#3604)
new c31b6f1 revise the schema default type not null (#3752)
new 88727f8 Upgrade third party libraries with security vulnerabilities (#3938)
new e115d53 Add tiered storage support for Pulsar SQL (#4045)
new d55306f Update bookkeeper ver to 4.9.1 (#4149)
new 79c8ba9 [WIP] PIP-36: Support set message size in broker.conf (#4247)
new af06cbc Upgrade to BookKeeper 4.9.2 (#4288)
new 799207c [schema] Fix joda dependency issue. (#4207)
new 19f0453 Use same activation dependency in pulsar-client-admin and pulsar-client (#4256)
new a8551ca rest: add swagger doc for tenants (#4421)
new 880231b Include pulsar-client-api in shaded client artifacts (#4445)
new 63e4d0f Bumped version to 2.5.0-SNAPSHOT (#4581)
new eb30230 Cleanup tests in the presto module (#4683)
new 29fe006 Upgrade to Mockito 2.x (#4671)
new 6093a0f Change type of publish_time to timestamp (#4757)
new b57462e Allow to configure ack-timeout tick time (#4760)
new a17b8e7 Convert anonymous classes to lambda (#4703)
new ed3c61a Add options to rewrite namespace delimiter for pulsar sql. (#4749)
new 290acd6 Pulsar SQL supports pulsar's primitive schema (#4728)
new f6b48ba add basic authentication capabilities to Pulsar SQL (#4779)
new 3ddcb57 Test cleanup and simplification (#4799)
new 7aea396 Reuse ManagedLedgerFactory instances across SQL queries (#4813)
new dd32602 Enforce checkstyle in the pulsar sql module (#4882)
new 6665a94 [pulsar-sql] Make partition as internal column (#4888)
new feb3ebe [pulsar-sql] Handle schema not found (#4890)
new e988f8e Upgrade jackson-databind (#5011)
new 4df6d85 Removed managed-ledger-shaded artifact (#4200)
new 824f65a Upgrade dependencies for security fixes (#5232)
new 8d24512 [zookeeper] bump zookeeper to version 3.5.6 (#5043)
new 699d2d6 Fix license file in the distribution package (#5578)
new 69fbb79 Upgrade bk version to 4.10.0 (#5607)
new 69f04ae [PIP-38] Support batch receive in java client. (#4621)
new 4b28e63 [Pulsar-sql]Using pulsar SQL query messages will appear `NoSuchLedger` when zk root directory changed (#5001)
new b6fb935 [transaction-coordinator] Implementation of transaction coordinator client. (#5680)
new 4248478 Bump version to 2.6.0 (#5820)
new fed85db [pulsar-sql]Expose configurations of managed ledger and bookkeeper client. (#5702)
new d90d524 Added catch for NoClassDefFoundError wherever there was a ClassNotFoundException (#5870)
new f81604d Upgrade Avro to 1.9.1 (#5938)
new 4996535 Pin the netty-transport-native-epoll to avoid conflicts (#6194)
new 2470f8a Namespace level offloader (#6183)
new a7cb318 PIP-45: Switch ManagedLedger to use MetadataStore interface (#5358)
new 92daa70 Upgrade ZooKeeper to 3.5.7 (#6329)
new 9c8fe8c KeyValue schema support for pulsar sql (#6325)
new 1495572 Bump netty version to 4.1.45.Final (#6424)
new 51c792b Remove duplicated test libraries in POM dependencies (#6430)
new 83408ae [minor]Reduce redundancy (#6611)
new a1306ab Support BouncyCastle FIPS provider (#6588)
new 9369067 Bump netty version to 4.1.48.Final (#6746)
new 3689576 Pulsar SQL Support Avro Schema `ByteBuffer` Type (#6925)
new eb980d3 Make Nar Extraction Directory configurable (#6933)
new 04a7ba2 Support multiple Avro schema version in Pulsar SQL (#4847)
new 41fb17d Fix presto SQL does not start prometheus service by default (#7030)
new 09078c8 Add pulsar SQL woker metrics to repo (#7031)
new 43f3b75 Remove double @Test annotations (#7063)
new ae83e13 update asynchttpclient verison (#7087)
new 6de748d [Pulsar SQL] Fix pulsar sql use multi zk address failed (#6947)
new 7b8ec7b Use pure-java Air-Compressor instead of JNI based libraries (#5390)
new 59819c0 [Issue 7202] Upgrade commons-lang3 version to 3.6 (#7203)
new f4cf0c7 Bumped version to 2.7.0-SNAPSHOT (#7233)
new e5802a7 Upgrade Presto version to 332 (#7194)
new f87ef1c Update Jetty to 9.4.29 (#7235)
new 82aee85 Update Jackson to 2.11.1 and ensure all dependencies are pinned (#7519)
new 05e2874 #5922 - Update poms to use project.groupId instead of org.apache.pulsar where applicable (#7548)
new 3ff60b8 Update Jersey to 2.31 (#7515)
new 0c5cb1e Avoid dependency on Apache HTTP client for TLS hostname verifier (#7612) (#7664)
new e9b068b [Pulsar SQL] Make Pulsar SQL get correct offload configurations (#7701)
new cdaac3c Fix security vulnerabilities of Pulsar (#7801)
new 73e6a5f [Pulsar SQL] Fix Pulsar SQL CI test (#7898)
new 4e45617 Upgrade jetty-util version to 9.4.31 (#8035)
new 75a2e6d Fix protobuf version to 3.11.4 (#8028)
new 1ce9764 Replace com.ning.asynchttpclient with org.asynchttpclient (#8099)
new 8e5af25 Upgrade Jcommander to 1.78 (#8206)
new b082567 Remove bouncy castle shaded module to avoid bring error of verifySingleJar (#7453)
new 16279e5 Sync license-maven-plugin version (#8367)
new f0f24e4 [Offload] Make the field name in `OffloadPolicies` match with config file (#8310)
new 01cab98 Allow building Apache Pulsar on JDK15+ - upgrade Maven Assembly Plugin (#8360)
new d380f1d Upgrade Apache BookKeeper Client to 4.11.1 (#8270)
new 5e716ac Upgrade jetty to 9.4.33.v20201020 (#8413)
new f0a2b57 [Bouncy Castle] include bc into pulsar-client fix docs (#8491)
new 6e75f1f Move pulsar-sql to top-level
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (b11a51c)
\
N -- N -- N refs/heads/master (6e75f1f)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
The 247 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.asf.yaml | 45 -
README.md | 3 -
pom.xml | 132 +++
presto-distribution/LICENSE | 572 ++++++++++++
presto-distribution/pom.xml | 361 ++++++++
presto-distribution/src/assembly/assembly.xml | 63 ++
.../java/org/openjdk/jol/info/ClassLayout.java | 53 ++
presto-pulsar-plugin/pom.xml | 81 ++
presto-pulsar-plugin/src/assembly/assembly.xml | 39 +
presto-pulsar/pom.xml | 183 ++++
.../pulsar/sql/presto/AvroSchemaHandler.java | 104 +++
.../pulsar/sql/presto/JSONSchemaHandler.java | 108 +++
.../pulsar/sql/presto/KeyValueSchemaHandler.java | 105 +++
.../pulsar/sql/presto/PulsarColumnHandle.java | 222 +++++
.../pulsar/sql/presto/PulsarColumnMetadata.java | 136 +++
.../apache/pulsar/sql/presto/PulsarConnector.java | 102 +++
.../pulsar/sql/presto/PulsarConnectorCache.java | 203 +++++
.../pulsar/sql/presto/PulsarConnectorConfig.java | 428 +++++++++
.../pulsar/sql/presto/PulsarConnectorFactory.java | 78 ++
.../pulsar/sql/presto/PulsarConnectorId.java | 56 ++
.../sql/presto/PulsarConnectorMetricsTracker.java | 356 ++++++++
.../pulsar/sql/presto/PulsarConnectorModule.java | 83 ++
.../pulsar/sql/presto/PulsarConnectorUtils.java | 102 +++
.../pulsar/sql/presto/PulsarHandleResolver.java | 85 ++
.../pulsar/sql/presto/PulsarInternalColumn.java | 246 ++++++
.../apache/pulsar/sql/presto/PulsarMetadata.java | 607 +++++++++++++
.../org/apache/pulsar/sql/presto/PulsarPlugin.java | 33 +
.../sql/presto/PulsarPrimitiveSchemaHandler.java | 63 ++
.../pulsar/sql/presto/PulsarRecordCursor.java | 612 +++++++++++++
.../apache/pulsar/sql/presto/PulsarRecordSet.java | 64 ++
.../pulsar/sql/presto/PulsarRecordSetProvider.java | 59 ++
.../pulsar/sql/presto/PulsarSchemaHandlers.java | 69 ++
.../org/apache/pulsar/sql/presto/PulsarSplit.java | 234 +++++
.../pulsar/sql/presto/PulsarSplitManager.java | 450 ++++++++++
.../sql/presto/PulsarSqlSchemaInfoProvider.java | 104 +++
.../pulsar/sql/presto/PulsarTableHandle.java | 122 +++
.../pulsar/sql/presto/PulsarTableLayoutHandle.java | 77 ++
.../pulsar/sql/presto/PulsarTopicDescription.java | 71 ++
.../pulsar/sql/presto/PulsarTransactionHandle.java | 28 +
.../apache/pulsar/sql/presto/SchemaHandler.java | 45 +
.../org/apache/pulsar/sql/presto/package-info.java | 22 +
.../META-INF/services/io.prestosql.spi.Plugin | 1 +
.../pulsar/sql/presto/TestAvroSchemaHandler.java | 127 +++
.../pulsar/sql/presto/TestPulsarConnector.java | 978 +++++++++++++++++++++
.../sql/presto/TestPulsarConnectorConfig.java | 103 +++
.../presto/TestPulsarKeyValueSchemaHandler.java | 353 ++++++++
.../pulsar/sql/presto/TestPulsarMetadata.java | 401 +++++++++
.../presto/TestPulsarPrimitiveSchemaHandler.java | 164 ++++
.../pulsar/sql/presto/TestPulsarRecordCursor.java | 195 ++++
.../pulsar/sql/presto/TestPulsarSplitManager.java | 404 +++++++++
50 files changed, 9284 insertions(+), 48 deletions(-)
delete mode 100644 .asf.yaml
delete mode 100644 README.md
create mode 100644 pom.xml
create mode 100644 presto-distribution/LICENSE
create mode 100644 presto-distribution/pom.xml
create mode 100644 presto-distribution/src/assembly/assembly.xml
create mode 100644 presto-distribution/src/main/java/org/openjdk/jol/info/ClassLayout.java
create mode 100644 presto-pulsar-plugin/pom.xml
create mode 100644 presto-pulsar-plugin/src/assembly/assembly.xml
create mode 100644 presto-pulsar/pom.xml
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/AvroSchemaHandler.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/JSONSchemaHandler.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/KeyValueSchemaHandler.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnHandle.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarColumnMetadata.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnector.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorCache.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorConfig.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorFactory.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorId.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorMetricsTracker.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorModule.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnectorUtils.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarHandleResolver.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarInternalColumn.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarPlugin.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarPrimitiveSchemaHandler.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordCursor.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordSet.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarRecordSetProvider.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSchemaHandlers.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplit.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSqlSchemaInfoProvider.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTableHandle.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTableLayoutHandle.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTopicDescription.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarTransactionHandle.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/SchemaHandler.java
create mode 100644 presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/package-info.java
create mode 100644 presto-pulsar/src/main/resources/META-INF/services/io.prestosql.spi.Plugin
create mode 100644 presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestAvroSchemaHandler.java
create mode 100644 presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnector.java
create mode 100644 presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarConnectorConfig.java
create mode 100644 presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarKeyValueSchemaHandler.java
create mode 100644 presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarMetadata.java
create mode 100644 presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarPrimitiveSchemaHandler.java
create mode 100644 presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarRecordCursor.java
create mode 100644 presto-pulsar/src/test/java/org/apache/pulsar/sql/presto/TestPulsarSplitManager.java