Skip to content
Permalink
Browse files
GIRAPH-1161
closes #50
  • Loading branch information
Jianlong Zhong authored and Maja Kabiljo committed Sep 29, 2017
1 parent 22e8511 commit 3bbac90fc37d225ff4eefaab018fe6147a5a0937
Showing 1 changed file with 1 addition and 0 deletions.
@@ -335,6 +335,7 @@ private List<InputSplit> generateInputSplits(GiraphInputFormat inputFormat,
INPUT_SPLIT_SAMPLE_PERCENT.get(getConfiguration());
if (samplePercent != INPUT_SPLIT_SAMPLE_PERCENT.getDefaultValue()) {
int lastIndex = (int) (samplePercent * splits.size() / 100f);
Collections.shuffle(splits);
List<InputSplit> sampleSplits = splits.subList(0, lastIndex);
LOG.warn(logPrefix + ": Using sampling - Processing only " +
sampleSplits.size() + " instead of " + splits.size() +

0 comments on commit 3bbac90

Please sign in to comment.