Commit 1f6d1f4
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 style1 parent 1ece67d commit 1f6d1f4
File tree
29 files changed
+3696
-0
lines changed- presto-flight-shim
- etc
- src
- main/java/com/facebook/presto/flightshim
- test
- java/com/facebook/presto/flightshim
- resources/certs
29 files changed
+3696
-0
lines changed| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
235 | 235 | | |
236 | 236 | | |
237 | 237 | | |
| 238 | + | |
238 | 239 | | |
239 | 240 | | |
240 | 241 | | |
| |||
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
| |||
| 1 | + | |
0 commit comments