-
Notifications
You must be signed in to change notification settings - Fork 3.4k
Add InfluxDB Connector #24220
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
base: master
Are you sure you want to change the base?
Add InfluxDB Connector #24220
Conversation
c26a3f8
to
caed040
Compare
I'm not sure if the CI fails because of the PR's code or if the tests are flaky ? |
|
caed040
to
480d66d
Compare
This pull request has gone a while without any activity. Tagging for triage help: @mosabua |
Closing this pull request, as it has been stale for six weeks. Feel free to re-open at any time. |
Hey @k3rnL Do you know what happened at the end? I will be happy to collaborate with you. I see your connector really interesting. 👍 |
A lack of time mostly ! The connector is working well, the problem is to be compliant with the autonomous tests.. |
480d66d
to
42a0cb4
Compare
@k3rnL Could you please update the pom.xml in (plugin/trino-influxdb) with this version of trino-root snapshot? and try again? 471 471-SNAPSHOT instead of 466-SNAPSHOT and then we will see what happen |
42a0cb4
to
b19ea18
Compare
Hi @k3rnL
Really excited to try your InfluxDB connector! I'm eager to collaborate once I have access. Let me know if you need help with these fixes 😊 |
b19ea18
to
e30e1f4
Compare
Seems @ebyhr just outperformed us 😁 Thank ! But I see that the merging is blocked because of a merge commit, but it seems this commit comes from the main branch itself. I may be mistaken, but I carefully rebased the code.. |
@k3rnL congrats you already passed all the tests. Do you know what is the next step? if not I will ask in the slack channel |
Perfect ! That was faster than I thought :) |
@k3rnL are you able to get this one through? |
462476d
to
ce212fb
Compare
Most errors in CI are related to this
|
ce212fb
to
d08634e
Compare
Yup, because I rebased with master, I've synced the version of trino parent in the pom of the connector and also addressed the comments of ebyhr. There is some changes that I couldn't test on my computer, finger crossed that all the unit tests works 🤞 |
a105a2a
to
5b531d8
Compare
That looks better :) |
@ebyhr Is this looking better now? |
# InfluxDB connector | ||
|
||
The InfluxDB Connector allows access to [InfluxDB](https://www.influxdata.com/) data from Trino. | ||
This document describes how to setup the InfluxDB Connector to run SQL queries against InfluxDB. |
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.
Wrap at 80 characters. Same for other places.
The connector maps InfluxDB types to the corresponding Trino types | ||
according to the following table: | ||
|
||
| InfluxDB type | Trino type | Notes | |
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.
Please use {list-table}
instead.
return createInfluxQueryRunner(server, REQUIRED_TPCH_TABLES); | ||
} | ||
|
||
@SuppressWarnings("DuplicateBranchesInSwitch") |
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.
Remove redundant suppression.
plugin/trino-influxdb/src/test/java/io/trino/plugin/influxdb/TestInfluxConnectorTest.java
Outdated
Show resolved
Hide resolved
plugin/trino-influxdb/src/test/java/io/trino/plugin/influxdb/TestInfluxConnectorTest.java
Outdated
Show resolved
Hide resolved
plugin/trino-influxdb/src/test/java/io/trino/plugin/influxdb/TestInfluxMetadata.java
Outdated
Show resolved
Hide resolved
plugin/trino-influxdb/src/test/java/io/trino/plugin/influxdb/TestInfluxMetadata.java
Outdated
Show resolved
Hide resolved
5b531d8
to
b0e8181
Compare
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.
I changed the implementation to use the non-deprecated method and solved the reminders.
ef05025
to
8f110cf
Compare
8f110cf
to
8e6dfdc
Compare
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.
I've made the corrections following your comments
This pull request has gone a while without any activity. Ask for help on #core-dev on Trino slack. |
@ebyhr Is there something more I can do ? |
This pull request has gone a while without any activity. Ask for help on #core-dev on Trino slack. |
Closing this pull request, as it has been stale for six weeks. Feel free to re-open at any time. |
Description
This PR introduces a new connector for InfluxDB, enabling Trino to query time-series data stored in InfluxDB. InfluxDB is a widely used time-series database but diverges from many traditional database standards, requiring a tailored approach to integration.
Additional context and related issues
I must note that most of the work was made in the past, but the PR was never finalized #15549
I have mostly only rebased the code, fixed tests and adapt the code to the new requirements.
My addition is the support for schema creation and schema/table destruction.
Release notes
( ) Release notes are required, with the following suggested text: