-
Notifications
You must be signed in to change notification settings - Fork 300
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
unifying vertica connector as jdbc connector #1918
Conversation
@@ -17,7 +17,7 @@ | |||
* limitations under the License. | |||
* #L% | |||
*/ | |||
package com.amazonaws.athena.connectors.vertica; | |||
package com.amazonaws.athena.connectors.vertica.qpt; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Is this class required any more? Why can't we just do what other SQL connectors are doing and use the QPT class in the JDBC package; specifically this: JdbcQueryPassthrough.java
and add the capabilities like MySQLMetadataHandler Line: 139
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Agree. pushed the required changes.
...ertica/src/test/java/com/amazonaws/athena/connectors/vertica/VerticaMetadataHandlerTest.java
Show resolved
Hide resolved
...ertica/src/test/java/com/amazonaws/athena/connectors/vertica/VerticaMetadataHandlerTest.java
Outdated
Show resolved
Hide resolved
...ertica/src/test/java/com/amazonaws/athena/connectors/vertica/VerticaMetadataHandlerTest.java
Outdated
Show resolved
Hide resolved
@@ -367,11 +328,14 @@ public void getPartitions(BlockWriter blockWriter, GetTableLayoutRequest request | |||
*/ | |||
@Override | |||
public GetSplitsResponse doGetSplits(BlockAllocator allocator, GetSplitsRequest request) | |||
throws SQLException | |||
{ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
it doesn't seem we are handling splits from QPT? Is that on purpose?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
you could use: setupQueryPassthroughSplit
from the parent class.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
here there is a somewhat different approach than other JDBC connectors. creating SQL statement from qpt args and exporting results to S3.
baa9f40
to
58d60fa
Compare
- Revert "build(deps): bump com.google.cloud:google-cloud-bigquery" (#1971) - build(deps): bump com.google.cloud:google-cloud-bigquery from 2.37.0 to 2.40.1 (#1962) - build(deps): bump com.google.cloud:google-cloud-bigquery - build(deps): bump com.google.api.grpc:grpc-google-cloud-bigquerystorage-v1 from 2.47.0 to 3.5.1 (#1961) - build(deps): bump com.google.api.grpc:grpc-google-cloud-bigquerystorage-v1 - build(deps): bump gremlinDriverVersion from 3.6.5 to 3.7.2 (#1967) - build(deps): bump gremlinDriverVersion from 3.6.5 to 3.7.2 - build(deps): bump com.google.cloud:google-cloud-resourcemanager from 1.44.0 to 1.45.0 (#1968) - build(deps): bump com.google.cloud:google-cloud-resourcemanager - build(deps): bump org.elasticsearch.client:elasticsearch-rest-client from 8.13.3 to 8.13.4 (#1970) - build(deps): bump org.elasticsearch.client:elasticsearch-rest-client - build(deps): bump com.amazon.redshift:redshift-jdbc42 from 2.1.0.26 to 2.1.0.27 (#1969) - build(deps): bump com.amazon.redshift:redshift-jdbc42 - build(deps): bump software.amazon.awssdk:bom from 2.25.45 to 2.25.50 (#1965) - build(deps): bump software.amazon.awssdk:bom from 2.25.45 to 2.25.50 - build(deps): bump com.google.cloud:google-cloud-storage from 2.37.0 to 2.38.0 (#1966) - build(deps): bump com.google.cloud:google-cloud-storage - build(deps): bump aws-sdk.version from 1.12.715 to 1.12.720 (#1964) - build(deps): bump aws-sdk.version from 1.12.715 to 1.12.720 - Enable map of complex types support (#1917) - unifying vertica connector as jdbc connector (#1918) - Feature/oracle fips (#1946) - Updated SigV4 signing library in Gremlin connection for Neptune connector (#1698)
- Snowflake split issue (#1963) - Com.google.cloud google cloud bigquery version update (#1975) - Fix ValidationException for Timestream connector (#1888) - build(deps): bump com.amazon.redshift:redshift-jdbc42 from 2.1.0.27 to 2.1.0.28 in /athena-redshift (#1974) - build(deps): bump com.amazon.redshift:redshift-jdbc42 - Updated prepare_dev_env.sh script (#1972) - Revert "build(deps): bump com.google.cloud:google-cloud-bigquery" (#1971) - build(deps): bump com.google.cloud:google-cloud-bigquery from 2.37.0 to 2.40.1 (#1962) - build(deps): bump com.google.cloud:google-cloud-bigquery - build(deps): bump com.google.api.grpc:grpc-google-cloud-bigquerystorage-v1 from 2.47.0 to 3.5.1 (#1961) - build(deps): bump com.google.api.grpc:grpc-google-cloud-bigquerystorage-v1 - build(deps): bump gremlinDriverVersion from 3.6.5 to 3.7.2 (#1967) - build(deps): bump gremlinDriverVersion from 3.6.5 to 3.7.2 - build(deps): bump com.google.cloud:google-cloud-resourcemanager from 1.44.0 to 1.45.0 (#1968) - build(deps): bump com.google.cloud:google-cloud-resourcemanager - build(deps): bump org.elasticsearch.client:elasticsearch-rest-client from 8.13.3 to 8.13.4 (#1970) - build(deps): bump org.elasticsearch.client:elasticsearch-rest-client - build(deps): bump com.amazon.redshift:redshift-jdbc42 from 2.1.0.26 to 2.1.0.27 (#1969) - build(deps): bump com.amazon.redshift:redshift-jdbc42 - build(deps): bump software.amazon.awssdk:bom from 2.25.45 to 2.25.50 (#1965) - build(deps): bump software.amazon.awssdk:bom from 2.25.45 to 2.25.50 - build(deps): bump com.google.cloud:google-cloud-storage from 2.37.0 to 2.38.0 (#1966) - build(deps): bump com.google.cloud:google-cloud-storage - build(deps): bump aws-sdk.version from 1.12.715 to 1.12.720 (#1964) - build(deps): bump aws-sdk.version from 1.12.715 to 1.12.720 - Enable map of complex types support (#1917) - unifying vertica connector as jdbc connector (#1918) - Feature/oracle fips (#1946) - Updated SigV4 signing library in Gremlin connection for Neptune connector (#1698)
Description of changes:
As suggested in qpt review comment, unified the vertical connector code as jdbc connector.
There are some changes in connector documentation as part of this PR. I will share doc separately.
By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your choice.