Move Caching Cluster Client to java streams and allow parallel intermediate merges#5913

Closed

drcrallen wants to merge 71 commits intoapache:masterfrom

drcrallen:cachingclient/streamport

Commits on Jun 20, 2018

Move some sequence implementations to Stream in Caching Clustered Client
Charles Allen
committed
Fix up build
Charles Allen
committed

Commits on Jun 21, 2018

Work on getting tests to pass
Charles Allen
committed
Don't use guava `Function
Charles Allen
committed
Tests pass!
Charles Allen
committed
General cleanup and refactoring for readability
Charles Allen
committed
Streams all around
Charles Allen
committed

Commits on Jun 22, 2018

PR comments
Charles Allen
committed

Commits on Jun 26, 2018

Add in parallel execution via FJP
Charles Allen
committed
Move to completion service... but risk deadlocking
Charles Allen
committed
Revert "Move to completion service... but risk deadlocking"
Charles Allen
committed
Actually make the stream parallel
Charles Allen
committed

Commits on Jun 27, 2018

Make the returned merge sequence fetch intermediate results asap
Charles Allen
committed
Pass Throwables
Charles Allen
committed
Code format
Charles Allen
committed
Eager materialize direct druid client sequences
Charles Allen
committed
Fix functionality test
Charles Allen
committed
Merge remote-tracking branch 'upstream/master' into cachingclient/streamport
Charles Allen
committed
Remove non-germane changes
Charles Allen
committed

Commits on Jul 13, 2018

LongAdder
Charles Allen
committed
Remove type arguments in test
Charles Allen
committed
Add HybridCache tests
Charles Allen
committed
Remove unused import
Charles Allen
committed
Merge remote-tracking branch 'apache/master' into cachingclient/streamport
Charles Allen
committed
Fix copyright
Charles Allen
committed
Copyrights
Charles Allen
committed

Commits on Jul 16, 2018

Annonymous fork join pool worker task
Charles Allen
committed
simple --> fromStream
Charles Allen
committed
Simple identity rename
Charles Allen
committed
Method ordering refactoring
Charles Allen
committed
Refactoring a bit and better javadoc descriptions
Charles Allen
committed
Formatting
Charles Allen
committed
Merge remote-tracking branch 'apache/master' into cachingclient/streamport
Charles Allen
committed

Commits on Jul 17, 2018

Add query context docs
Charles Allen
committed

Commits on Jul 25, 2018

Add FJP friendly methods
Charles Allen
committed
Change streams to use fjp for merge work
Charles Allen
committed
Fix missed merge conflict
Charles Allen
committed
Fix missed merge in test
Charles Allen
committed
Use non-forbidden api
Charles Allen
committed
Fix merge conflict
Charles Allen
committed
Fix more missed merge conflicts
Charles Allen
committed
Merge remote-tracking branch 'apache/master' into cachingclient/streamport
Charles Allen
committed
Don't use forbidden apis again
Charles Allen
committed
More forbidden apis
Charles Allen
committed

Commits on Jul 30, 2018

Merge remote-tracking branch 'apache/master' into cachingclient/streamport
Charles Allen
committed
Add Execs.checkThreadNameFormat
Charles Allen
committed
Pretty deadline caluclating in ChainedExecutionQueryRunner
Charles Allen
committed
Add javadoc
Charles Allen
committed
Refactor to split out functions some more
Charles Allen
committed
Use atomic long for state in fork join naming
Charles Allen
committed

Commits on Aug 6, 2018

UCASE constant
Charles Allen
committed

Commits on Aug 8, 2018

Merge remote-tracking branch 'apache/master' into cachingclient/streamport
Charles Allen
committed
Address code comments
Charles Allen
committed

Commits on Aug 17, 2018

Merge remote-tracking branch 'apache/master' into cachingclient/streamport
Charles Allen
committed

Commits on Aug 27, 2018

Merge remote-tracking branch 'apache/master' into cachingclient/streamport
Charles Allen
committed
Add tests for deadline
Charles Allen
committed

Commits on Aug 29, 2018

Merge remote-tracking branch 'apache/master' into cachingclient/streamport
Charles Allen
committed
Address code comments
Charles Allen
committed
Add more examples
Charles Allen
committed
newline
Charles Allen
committed
Super awesome mega array preallocation
Charles Allen
committed
Add java docs explaining fork/join mechanism
Charles Allen
committed
Move some things to single line
Charles Allen
committed
Code formatting
Charles Allen
committed
Fix code formatting
Charles Allen
committed

Commits on Sep 5, 2018

Merge remote-tracking branch 'apache/master' into cachingclient/streamport
Charles Allen
committed

Commits on Sep 21, 2018

Merge remote-tracking branch 'apache/master' into cachingclient/streamport
Charles Allen
committed

Commits on Oct 4, 2018

Merge remote-tracking branch 'apache/master' into cachingclient/streamport
Charles Allen
committed
Get rid of divide by zero
Charles Allen
committed
Start addressing comments
Charles Allen
committed

Commits on Oct 17, 2018

Merge remote-tracking branch 'apache/master' into cachingclient/streamport
Charles Allen
committed