Conversation
a777aeb to
c0beafd
Compare
Codecov Report
@@ Coverage Diff @@
## master #104 +/- ##
============================================
- Coverage 87.50% 87.35% -0.16%
- Complexity 2933 2988 +55
============================================
Files 308 314 +6
Lines 10999 11195 +196
Branches 941 964 +23
============================================
+ Hits 9625 9779 +154
- Misses 929 957 +28
- Partials 445 459 +14
Continue to review full report at Codecov.
|
| for (int i = 0; i < size; i++) { | ||
| Id id = this.graphFactory.createId(); | ||
| id.read(in); | ||
| Value<?> value = this.graphFactory.createValue(ValueType.DOUBLE); | ||
| value.read(in); | ||
| this.map.put(id, (DoubleValue) value); | ||
| } |
There was a problem hiding this comment.
let ClosenessValue extend MapValue, or just use MapValue class?
353e56a to
e6be433
Compare
| } | ||
|
|
||
| @Override | ||
| public Object object() { |
| * until any queue is available | ||
| */ | ||
| if (emptyQueueCount >= channelCount) { | ||
| LOG.info("The send executor was blocked " + |
There was a problem hiding this comment.
It will lead too many print info
There was a problem hiding this comment.
will not lead too many print info?
| * until any client is available | ||
| */ | ||
| if (busyClientCount >= channelCount) { | ||
| LOG.info("The send executor was blocked " + |
There was a problem hiding this comment.
It will lead too many print info
| MapValue<DoubleValue> localValue = vertex.value(); | ||
| // Cumulative distance | ||
| double centrality = 0; | ||
| for (Map.Entry<Id, DoubleValue> entry : localValue.entrySet()) { | ||
| centrality += 1.0D / entry.getValue().value(); |
There was a problem hiding this comment.
What mean? Move the for-loop logic into string() method?
There was a problem hiding this comment.
I mean try to let ClosenessCentralityValue extends MapValue, move this block to ClosenessCentralityValue.value()/string(), and delete ClosenessCentralityLogOutput since LimitedLogOutput can log through ClosenessCentralityValue.string()
| * until any queue is available | ||
| */ | ||
| if (emptyQueueCount >= channelCount) { | ||
| LOG.info("The send executor was blocked " + |
There was a problem hiding this comment.
will not lead too many print info?
| .put("F", 1.45) | ||
| .build(); | ||
|
|
||
| public Vertex constructHugeVertex( |
There was a problem hiding this comment.
override value() method instead
| .put("F", 3.333333333333333) | ||
| .build(); | ||
|
|
||
| public Vertex constructHugeVertex( |
| MapValue<DoubleValue> localValue = vertex.value(); | ||
| // Cumulative distance | ||
| double centrality = 0; | ||
| for (Map.Entry<Id, DoubleValue> entry : localValue.entrySet()) { | ||
| centrality += 1.0D / entry.getValue().value(); |
There was a problem hiding this comment.
I mean try to let ClosenessCentralityValue extends MapValue, move this block to ClosenessCentralityValue.value()/string(), and delete ClosenessCentralityLogOutput since LimitedLogOutput can log through ClosenessCentralityValue.string()
b712b05 to
92d9c53
Compare
No description provided.