-
Notifications
You must be signed in to change notification settings - Fork 16
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
Native cql changes #606
Native cql changes #606
Conversation
… native_cql_changes
… native_cql_changes
… native_cql_changes
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.
Lots of great work in here. My main concerns are:
- We still have quite a bit of usage of bridge / gRPC proto classes. Should we create a followup ticket to complete this removal?
- There appear to be quite a few tests that are still disabled. Which of these will be re-enabled before we merge this PR?
src/main/java/io/stargate/sgv2/jsonapi/config/OperationsConfig.java
Outdated
Show resolved
Hide resolved
src/main/java/io/stargate/sgv2/jsonapi/exception/mappers/ThrowableToErrorMapper.java
Show resolved
Hide resolved
src/main/java/io/stargate/sgv2/jsonapi/service/bridge/executor/CollectionSettings.java
Show resolved
Hide resolved
src/main/java/io/stargate/sgv2/jsonapi/service/bridge/executor/QueryExecutor.java
Outdated
Show resolved
Hide resolved
src/test/java/io/stargate/sgv2/jsonapi/service/cqldriver/CqlSessionCacheTest.java
Outdated
Show resolved
Hide resolved
import org.junit.jupiter.api.Nested; | ||
import org.junit.jupiter.api.Test; | ||
|
||
@QuarkusTest | ||
@Disabled |
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.
Are we planning to re-enable this test at some point?
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.
Need to figure out how to mock AsyncResultSet., then can be re-enabled.
import org.junit.jupiter.api.Nested; | ||
import org.junit.jupiter.api.Test; | ||
|
||
@QuarkusTest | ||
@Disabled |
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.
When do we plan to re-enable?
@@ -44,7 +65,7 @@ public void partitionColumnsTooMany() { | |||
QueryOuterClass.ColumnSpec.newBuilder().setName("key2").build()) | |||
.build(); | |||
|
|||
boolean result = tableMatcher.test(table); | |||
boolean result = tableMatcher.test(null); |
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.
hmm wondering why this would be null? here and other cases below. I do see this class is disabled.
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.
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.
All the data structures in JsonapiTable
have been changed and I have to rewrite all the unit tests. To save time, I didn't do that and just replaced the null
to avoid the compile error. I will fix that later with all the unit tests.
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.
@Hazel-Datastax Can you create an issue to fix this so can be taken at later time?
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.
Sure
@@ -0,0 +1,264 @@ | |||
// |
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.
This is temporary right? Are we planning to remove this class copied from main stargate repo prior to merging? (Presumably because Stargate version is updated with what we need)
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.
Yes., Will remove this once the stargate api release is done.
src/main/java/io/stargate/sgv2/jsonapi/service/bridge/executor/QueryExecutor.java
Outdated
Show resolved
Hide resolved
src/main/java/io/stargate/sgv2/jsonapi/service/operation/model/impl/FindOperation.java
Outdated
Show resolved
Hide resolved
src/main/java/io/stargate/sgv2/jsonapi/config/OperationsConfig.java
Outdated
Show resolved
Hide resolved
src/main/java/io/stargate/sgv2/jsonapi/config/OperationsConfig.java
Outdated
Show resolved
Hide resolved
src/main/java/io/stargate/sgv2/jsonapi/service/bridge/executor/QueryExecutor.java
Outdated
Show resolved
Hide resolved
src/main/java/io/stargate/sgv2/jsonapi/service/bridge/executor/QueryExecutor.java
Outdated
Show resolved
Hide resolved
src/main/java/io/stargate/sgv2/jsonapi/service/cqldriver/TenantAwareCqlSessionBuilder.java
Show resolved
Hide resolved
src/main/java/io/stargate/sgv2/jsonapi/service/cqldriver/CQLSessionCache.java
Show resolved
Hide resolved
src/main/java/io/stargate/sgv2/jsonapi/service/cqldriver/CQLSessionCache.java
Outdated
Show resolved
Hide resolved
… native_cql_changes
String localDatacenter(); | ||
|
||
/** Time to live for CQLSession in cache in seconds. */ | ||
@WithDefault("300") |
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.
Are we sure we really want 5 minutes over 1 -- this is not time-to-live for connection (AFAIK) but time unused connection remains for reuse after last call. That is, idle wait.
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.
When session is evicted from cache, the session will be closed. Changed to 300 as per yesterday's conversation.
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.
Also these values can be override using environment value in the chart.
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.
Changes based on review feedback are complete and issues were created for follow up items, approving.
What this PR does:
Which issue(s) this PR fixes:
Fixes #
Checklist