Author: cdouglas
Date: Sat Feb 28 01:36:29 2009
New Revision: 748767
URL: http://svn.apache.org/viewvc?rev=748767&view=rev
Log:
HADOOP-5111. Fix Job::set* methods to work with generics.
Modified:
hadoop/core/branches/branch-0.20/CHANGES.txt
hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapreduce/Job.java
Modified: hadoop/core/branches/branch-0.20/CHANGES.txt
URL:
http://svn.apache.org/viewvc/hadoop/core/branches/branch-0.20/CHANGES.txt?rev=748767&r1=748766&r2=748767&view=diff
==============================================================================
--- hadoop/core/branches/branch-0.20/CHANGES.txt (original)
+++ hadoop/core/branches/branch-0.20/CHANGES.txt Sat Feb 28 01:36:29 2009
@@ -670,6 +670,8 @@
HADOOP-5306. Fixes a problem to do with logging/parsing the http port of a
lost tracker. Affects JobTracker restart. (Amar Kamat via ddas)
+ HADOOP-5111. Fix Job::set* methods to work with generics. (cdouglas)
+
Release 0.19.2 - Unreleased
BUG FIXES
Modified:
hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapreduce/Job.java
URL:
http://svn.apache.org/viewvc/hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapreduce/Job.java?rev=748767&r1=748766&r2=748767&view=diff
==============================================================================
---
hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapreduce/Job.java
(original)
+++
hadoop/core/branches/branch-0.20/src/mapred/org/apache/hadoop/mapreduce/Job.java
Sat Feb 28 01:36:29 2009
@@ -110,7 +110,7 @@
* @param cls the <code>Mapper</code> to use
* @throws IllegalStateException if the job is submitted
*/
- public void setMapperClass(Class<? extends Mapper<?,?,?,?>> cls
+ public void setMapperClass(Class<? extends Mapper> cls
) throws IllegalStateException {
ensureState(JobState.DEFINE);
conf.setClass(MAP_CLASS_ATTR, cls, Mapper.class);
@@ -137,7 +137,7 @@
* @param cls the combiner to use
* @throws IllegalStateException if the job is submitted
*/
- public void setCombinerClass(Class<? extends Reducer<?,?,?,?>> cls
+ public void setCombinerClass(Class<? extends Reducer> cls
) throws IllegalStateException {
ensureState(JobState.DEFINE);
conf.setClass(COMBINE_CLASS_ATTR, cls, Reducer.class);
@@ -148,7 +148,7 @@
* @param cls the <code>Reducer</code> to use
* @throws IllegalStateException if the job is submitted
*/
- public void setReducerClass(Class<? extends Reducer<?,?,?,?>> cls
+ public void setReducerClass(Class<? extends Reducer> cls
) throws IllegalStateException {
ensureState(JobState.DEFINE);
conf.setClass(REDUCE_CLASS_ATTR, cls, Reducer.class);
@@ -159,7 +159,7 @@
* @param cls the <code>Partitioner</code> to use
* @throws IllegalStateException if the job is submitted
*/
- public void setPartitionerClass(Class<? extends Partitioner<?,?>> cls
+ public void setPartitionerClass(Class<? extends Partitioner> cls
) throws IllegalStateException {
ensureState(JobState.DEFINE);
conf.setClass(PARTITIONER_CLASS_ATTR, cls, Partitioner.class);
@@ -223,7 +223,7 @@
* @param cls the raw comparator
* @throws IllegalStateException if the job is submitted
*/
- public void setSortComparatorClass(Class<? extends RawComparator<?>> cls
+ public void setSortComparatorClass(Class<? extends RawComparator> cls
) throws IllegalStateException {
ensureState(JobState.DEFINE);
conf.setOutputKeyComparatorClass(cls);
@@ -237,7 +237,7 @@
* @param cls the raw comparator to use
* @throws IllegalStateException if the job is submitted
*/
- public void setGroupingComparatorClass(Class<? extends RawComparator<?>> cls
+ public void setGroupingComparatorClass(Class<? extends RawComparator> cls
) throws IllegalStateException {
ensureState(JobState.DEFINE);
conf.setOutputValueGroupingComparator(cls);
