-
Notifications
You must be signed in to change notification settings - Fork 504
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
optimize aggregate functions #813
Conversation
|
||
System.out.println(">>>>num4="+ | ||
graph.traversal().V().hasLabel("person").both().values("age").sum().toList()); | ||
|
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
} | ||
|
||
@Override | ||
// @SuppressWarnings({ "rawtypes", "unchecked" }) |
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 //
Aggregate aggregate = query.aggregateNotNull(); | ||
Iterator<Number> results = this.query(query, statement -> { | ||
// Set request timeout to a large value | ||
// TODO read from conf |
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.
TODO
try { | ||
return this.store.queryNumber(squery); | ||
} finally { | ||
this.afterRead(); // TODO: not complete the iteration currently |
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 TODO
private AggregationClient aggregationClient() { | ||
Configuration hConfig = this.hbase.getConfiguration(); | ||
hConfig = HBaseConfiguration.create(hConfig); | ||
// TODO: read from conf |
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.
TODO
Change-Id: I87af5f447c06e7a42c077d3d9eb1a3acde9d3b66
Change-Id: If8579e920d950b5573a87f25b1f79f34b7114ca1
Change-Id: Iab39d76c764f0b3ed3953be54dcebe51eb8afb7c
Change-Id: I09dc9aad7458d17e1b7b5b76fa028edbee5501b4
Change-Id: Ie68884edf56c552e1add6158cd82a1c3588bf6eb
Change-Id: Ic83b5c55db8ea089b6adaa9491757a52a9d59cfe
Change-Id: Icf781d62b09c617c0a2585d8b389617ae4711c63
Change-Id: I58c646b4699f1d0653807cb7b9e0a0e2acaaa404
5e4f5bc
to
3c403d1
Compare
Change-Id: I636ff6c84444f81bdb86eb6efcb040530d85fef8
Change-Id: I0b5a740078251b77d88b8490e9cde965bfe5696c
Change-Id: I4bb9bf21126b62bd58f3c5b1f4b1d8513c385612
56def1e
to
5d8d2c3
Compare
hadoop depend on jersey 1.9 Change-Id: I7ceab1896b9b72725b1d50327aa66f4396ec8806
30ba06e
to
01d72da
Compare
java.lang.AbstractMethodError: javax.ws.rs.core.UriBuilder.uri
|
Change-Id: I3332044f18601076e8c56b66353561ac31793ffd
01d72da
to
6bfd54b
Compare
Change-Id: If223f62970276e02d4c74877fae811c10afe6459
Codecov Report
@@ Coverage Diff @@
## master #813 +/- ##
============================================
- Coverage 72.30% 72.24% -0.07%
- Complexity 4511 4567 +56
============================================
Files 287 290 +3
Lines 21464 21742 +278
Branches 3040 3079 +39
============================================
+ Hits 15520 15707 +187
- Misses 4428 4499 +71
- Partials 1516 1536 +20
Continue to review full report at Codecov.
|
implement: #580 #710
Change-Id: I87af5f447c06e7a42c077d3d9eb1a3acde9d3b66