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
output demo(pagerank) #72
Conversation
Codecov Report
@@ Coverage Diff @@
## master #72 +/- ##
============================================
- Coverage 88.10% 87.58% -0.52%
- Complexity 2632 2685 +53
============================================
Files 270 281 +11
Lines 9926 10206 +280
Branches 836 847 +11
============================================
+ Hits 8745 8939 +194
- Misses 770 850 +80
- Partials 411 417 +6
Continue to review full report at Codecov.
|
ff29dab
to
e2fd20d
Compare
public static final ConfigOption<Integer> OUTPUT_BATCH_SIZE = | ||
new ConfigOption<>( | ||
"output.batch_size", | ||
"The batch size of output", | ||
positiveInt(), | ||
500 | ||
); | ||
|
||
public static final ConfigOption<Integer> OUTPUT_BATCH_THREADS = | ||
new ConfigOption<>( | ||
"output.batch_threads", | ||
"The threads number used to batch output", | ||
positiveInt(), | ||
1 | ||
); | ||
|
||
public static final ConfigOption<Integer> OUTPUT_SINGLE_THREADS = | ||
new ConfigOption<>( | ||
"output.single_threads", | ||
"The threads number used to single output", | ||
positiveInt(), | ||
1 | ||
); | ||
|
||
public static final ConfigOption<Integer> | ||
OUTPUT_THREAD_POOL_SHUTDOWN_TIMEOUT = | ||
new ConfigOption<>( | ||
"output.thread_pool_shutdown_timeout", | ||
"The timeout seconds of output threads pool shutdown", | ||
positiveInt(), | ||
60 | ||
); | ||
|
||
public static final ConfigOption<Integer> OUTPUT_RETRY_TIMES = | ||
new ConfigOption<>( | ||
"output.retry_times", | ||
"The retry times when output failed", | ||
positiveInt(), | ||
3 | ||
); | ||
|
||
public static final ConfigOption<Integer> OUTPUT_RETRY_INTERVAL = | ||
new ConfigOption<>( | ||
"output.retry_interval", | ||
"The retry interval when output failed", | ||
positiveInt(), | ||
10 | ||
); | ||
|
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.
copy a copy to the driver
e2fd20d
to
671962e
Compare
positiveInt(), | ||
Integer.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.
can move some options of ComputerOptions to api module?
c0aeb86
to
3ed4b67
Compare
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.
expect codecov improvement: codecov/patch — 66.54% of diff hit (target 88.10%)
@@ -42,6 +42,6 @@ public void setAlgorithmParameters(Map<String, String> params) { | |||
this.setIfAbsent(params, ComputerOptions.WORKER_COMBINER_CLASS, | |||
DoubleValueSumCombiner.class.getName()); | |||
this.setIfAbsent(params, ComputerOptions.OUTPUT_CLASS, | |||
LimitedLogOutput.class.getName()); | |||
PageRankOutput.class.getName()); |
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 update other algorithms?
"output.retry_interval", | ||
positiveInt(), | ||
Integer.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.
can move some options of ComputerOptions to api module?
<groupId>org.apache.commons</groupId> | ||
<artifactId>commons-lang3</artifactId> | ||
<version>3.9</version> | ||
</dependency> |
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.
seems it's included by hugegraph-common
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.
The version depended by hugegraph-common is low, so need to include explicitly
No description provided.