Skip to content

Commit f65e31d

Browse files
committed
Adding initial files, rough WIP
Works up to getting RecordSet due to classloader conflict Test is now able to read from postgresql into recordset Using FlightShimConfig for location Added conversion with ArrowShimWriter Added more type conversions and writers Config with SSL working, test passes with row count Fix test for tpch Using executor service to run getStream Adding cancel tests Backpressure working Fixed config to load from file Added some basic unit tests Using bound FunctionAndTypeManager for type deser and ConnectorContext Made FlightShimQueryRunner, working but needs selecting columns Able to make select query by column name and use query runner Added test for MySql connector Added type support for date and timestamp, with tests. decimal test not working yet Fix floating point test Added logging Using plugins from plugin-bundles config Added oracle and singlestore tests, oracle not working yet Remove plugin dir Fixed deser of TupleDomain, need to test against query results Add test with additionalPredicate Enable mTLS, fix config typo Moved to test containers after rebase Fix code style
1 parent 1ece67d commit f65e31d

28 files changed

+3695
-0
lines changed

pom.xml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -235,6 +235,7 @@
235235
<module>presto-plan-checker-router-plugin</module>
236236
<module>presto-sql-helpers/presto-sql-invoked-functions-plugin</module>
237237
<module>presto-sql-helpers/presto-native-sql-invoked-functions-plugin</module>
238+
<module>presto-flight-shim</module>
238239
</modules>
239240

240241
<dependencyManagement>
Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,10 @@
1+
flight-shim.server=localhost
2+
flight-shim.server.port=9999
3+
flight-shim.server-ssl-certificate-file=src/test/resources/certs/server.crt
4+
flight-shim.server-ssl-key-file=src/test/resources/certs/server.key
5+
6+
plugin.bundles=\
7+
../presto-oracle/pom.xml,\
8+
../presto-postgresql/pom.xml,\
9+
../presto-mysql/pom.xml,\
10+
../presto-singlestore/pom.xml
Lines changed: 13 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
#
2+
# WARNING
3+
# ^^^^^^^
4+
# This configuration file is for development only and should NOT be used be
5+
# used in production. For example configuration, see the Presto documentation.
6+
#
7+
#com.=INFO
8+
com.facebook.presto.execution=DEBUG
9+
com.facebook.presto=INFO
10+
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory=WARN
11+
com.ning.http.client=WARN
12+
com.facebook.presto.server.PluginManager=DEBUG
13+
com.facebook.presto.flightshim=DEBUG

0 commit comments

Comments
 (0)