diff --git a/java/src/main/java/com/google/appengine/tools/mapreduce/MapReduceJob.java b/java/src/main/java/com/google/appengine/tools/mapreduce/MapReduceJob.java index ea32ca94..6b8455de 100644 --- a/java/src/main/java/com/google/appengine/tools/mapreduce/MapReduceJob.java +++ b/java/src/main/java/com/google/appengine/tools/mapreduce/MapReduceJob.java @@ -105,6 +105,9 @@ enum Stage { */ Key getMapReduceJobKey(); + /** + * @return identifier for *this* sharded job + */ default ShardedJobId getShardedJobId() { return ShardedJobId.of(getMapReduceJobKey().getProjectId(), getMapReduceJobKey().getNamespace(), getStageId()); } @@ -274,7 +277,7 @@ public String toString() { } /** - * Takes in the the result of the map stage. (FilesByShard indexed by sortShard) These files are + * Takes in the result of the map stage. (FilesByShard indexed by sortShard) These files are * then read, and written out in sorted order. The result is a set of files for each reducer. * The format for how the data is written out is defined by {@link GoogleCloudStorageSortOutput} */