[
https://issues.apache.org/jira/browse/GIRAPH-1147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16016535#comment-16016535
]
ASF GitHub Bot commented on GIRAPH-1147:
----------------------------------------
Github user dlogothetis commented on a diff in the pull request:
https://github.com/apache/giraph/pull/38#discussion_r117364342
--- Diff:
giraph-core/src/main/java/org/apache/giraph/master/input/MasterInputSplitsHandler.java
---
@@ -56,16 +69,39 @@
/** Latches to say when one input splits type is ready to be accessed */
private Map<InputType, CountDownLatch> latchesMap =
new EnumMap<>(InputType.class);
+ /** Context for accessing counters */
+ private final Mapper.Context context;
+ /** How many splits per type are there total */
+ private final Map<InputType, Integer> numSplitsPerType =
+ new EnumMap<>(InputType.class);
+ /** How many splits per type have been read so far */
+ private final Map<InputType, AtomicInteger> numSplitsReadPerType =
+ new EnumMap<>(InputType.class);
+ /**
+ * Store in counters timestamps when we finished reading
+ * these fractions of input
+ */
+ private final double[] doneFractionsToStoreInCoutners;
--- End diff --
Typo in field name.
> Store timestamps when various fractions of input were done
> ----------------------------------------------------------
>
> Key: GIRAPH-1147
> URL: https://issues.apache.org/jira/browse/GIRAPH-1147
> Project: Giraph
> Issue Type: New Feature
> Reporter: Maja Kabiljo
> Assignee: Maja Kabiljo
> Priority: Minor
>
> In order to evaluate how read stragglers affect job performance, add a way to
> expose timestamps when various fractions of input were done reading through
> counters.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
