-
Notifications
You must be signed in to change notification settings - Fork 1k
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
feat(static): static select support #3369
feat(static): static select support #3369
Conversation
static queries now support arbitrary select expressions.
|
||
@SuppressWarnings("OptionalGetWithoutIsPresent") | ||
@RunWith(MockitoJUnitRunner.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.
This test was actually just renamed to QueryAnalyzerFunctionalTest
. This is just a bad diff by Git.
QueryAnalyzerFunctionalTest
continuous to be a functional style that parses actual sql and then analyses it.
QueryAnalyzerTest
is now a unit test.
* <p>This test file is more of a functional test, which is better implemented using QTT. | ||
*/ | ||
@SuppressWarnings("OptionalGetWithoutIsPresent") | ||
public class QueryAnalyzerFunctionalTest { |
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.
renamed from QueryAnalyzerTest
. Please do not review this file - I haven't changed it!
ksql-engine/src/main/java/io/confluent/ksql/analyzer/QueryValidator.java
Outdated
Show resolved
Hide resolved
ksql-engine/src/main/java/io/confluent/ksql/analyzer/StaticQueryValidator.java
Outdated
Show resolved
Hide resolved
ksql-engine/src/test/java/io/confluent/ksql/analyzer/ContinuousQueryValidatorTest.java
Outdated
Show resolved
Hide resolved
ksql-engine/src/test/java/io/confluent/ksql/analyzer/ExpressionAnalyzerTest.java
Show resolved
Hide resolved
ksql-engine/src/test/java/io/confluent/ksql/analyzer/ExpressionAnalyzerTest.java
Show resolved
Hide resolved
ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/execution/StaticQueryExecutor.java
Show resolved
Hide resolved
ksql-rest-app/src/main/java/io/confluent/ksql/rest/server/execution/StaticQueryExecutor.java
Show resolved
Hide resolved
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.
LGTM. Just some nits.
Description
static queries now support arbitrary select expressions, e.g.
As part of this PR I've looked to start to make use of the
QueryAnalyzer
to analyze static queries. I've also pulled the validation of static and continuous queries into their own validator classes, to make them more targeted:StaticQueryValidator
andContinuousQueryValiator
, respectively.As before, don't worry overly about the code in
StaticQueryExecutor
- it's temporary.Testing done
Suitable tests added, then
mvn test
Reviewer checklist