Skip to content
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.

Sign up for GitHub

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

Jump to bottom

feat: Add support for IN clause to pull queries #6409

Merged
merged 18 commits into from
Oct 22, 2020
Merged

feat: Add support for IN clause to pull queries #6409

Changes from 1 commit
Commits
Show all changes
18 commits
Select commit Hold shift + click to select a range
74f95f8
Basic version
AlanConfluent Oct 8, 2020
332017d
Groups queries by location
AlanConfluent Oct 8, 2020
6b89705
Makes it multithreaded
AlanConfluent Oct 9, 2020
db742d1
Reworked to work with window functions
AlanConfluent Oct 9, 2020
e02ab18
Gets tests working
AlanConfluent Oct 12, 2020
41f34c1
mvn validate
AlanConfluent Oct 12, 2020
40ee19a
Adds rest query validation tests
AlanConfluent Oct 12, 2020
cd573e0
Fixes test
AlanConfluent Oct 12, 2020
f505f71
Feedback
AlanConfluent Oct 13, 2020
4b662c8
Revert change to RestQueryTranslationTest
AlanConfluent Oct 13, 2020
fb493c2
Changes to reorganize by host each time
AlanConfluent Oct 15, 2020
1a55d1f
Changed to using partition rather than rewriting keys
AlanConfluent Oct 15, 2020
c13a9c8
Removes key dups
AlanConfluent Oct 15, 2020
4888c57
Uncomments KsLocatorTest.java and adds a case
AlanConfluent Oct 15, 2020
54f8359
Ups threads to 100
AlanConfluent Oct 16, 2020
f721ccb
Fixes RestQueryTranslationTest
AlanConfluent Oct 19, 2020
09a06dd
Adds Comments
AlanConfluent Oct 20, 2020
d59cdfb
Renames KsqlLocation to KsqlPartitionLocation
AlanConfluent Oct 21, 2020
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Ups threads to 100
  • Loading branch information
@AlanConfluent
AlanConfluent committed Oct 16, 2020
commit 54f835998ab81a43eb2ccea2f7d84ef24da1a0ae
2 changes: 1 addition & 1 deletion ksqldb-common/src/main/java/io/confluent/ksql/util/KsqlConfig.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -235,7 +235,7 @@ public class KsqlConfig extends AbstractConfig {

public static final String KSQL_QUERY_PULL_THREAD_POOL_SIZE_CONFIG
= "ksql.query.pull.thread.pool.size";
public static final Integer KSQL_QUERY_PULL_THREAD_POOL_SIZE_DEFAULT = 40;
public static final Integer KSQL_QUERY_PULL_THREAD_POOL_SIZE_DEFAULT = 100;
public static final String KSQL_QUERY_PULL_THREAD_POOL_SIZE_DOC =
"Size of thread pool used for sending/executing pull queries";

Expand Down