|
@@ -42,11 +42,12 @@ import org.apache.log4j.Logger;
|
|
* result of deprecation some keys change or are preferred over other keys,
|
|
* result of deprecation some keys change or are preferred over other keys,
|
|
* across versions. {@link MapReduceJobPropertiesParser} is a utility class that
|
|
* across versions. {@link MapReduceJobPropertiesParser} is a utility class that
|
|
* parses MapReduce job configuration properties and converts the value into a
|
|
* parses MapReduce job configuration properties and converts the value into a
|
|
- * well defined {@link DataType}. Users can use the
|
|
|
|
- * {@link MapReduceJobPropertiesParser#parseJobProperty()} API to process job
|
|
|
|
- * configuration parameters. This API will parse a job property represented as a
|
|
|
|
- * key-value pair and return the value wrapped inside a {@link DataType}.
|
|
|
|
- * Callers can then use the returned {@link DataType} for further processing.
|
|
|
|
|
|
+ * well defined {@link DataType}. Users can use the
|
|
|
|
+ * {@link MapReduceJobPropertiesParser#parseJobProperty(String, String)} API to
|
|
|
|
+ * process job configuration parameters. This API will parse a job property
|
|
|
|
+ * represented as a key-value pair and return the value wrapped inside a
|
|
|
|
+ * {@link DataType}. Callers can then use the returned {@link DataType} for
|
|
|
|
+ * further processing.
|
|
*
|
|
*
|
|
* {@link MapReduceJobPropertiesParser} thrives on the key name to decide which
|
|
* {@link MapReduceJobPropertiesParser} thrives on the key name to decide which
|
|
* {@link DataType} to wrap the value with. Values for keys representing
|
|
* {@link DataType} to wrap the value with. Values for keys representing
|
|
@@ -61,14 +62,14 @@ import org.apache.log4j.Logger;
|
|
* {@link DefaultDataType}. Currently only '-Xmx' and '-Xms' settings are
|
|
* {@link DefaultDataType}. Currently only '-Xmx' and '-Xms' settings are
|
|
* considered while the rest are ignored.
|
|
* considered while the rest are ignored.
|
|
*
|
|
*
|
|
- * Note that the {@link MapReduceJobPropertiesParser#parseJobProperty()} API
|
|
|
|
- * maps the keys to a configuration parameter listed in
|
|
|
|
|
|
+ * Note that the {@link MapReduceJobPropertiesParser#parseJobProperty(String,
|
|
|
|
+ * String)} API maps the keys to a configuration parameter listed in
|
|
* {@link MRJobConfig}. This not only filters non-framework specific keys thus
|
|
* {@link MRJobConfig}. This not only filters non-framework specific keys thus
|
|
- * ignoring user-specific and hard-to-parse keys but also provides a consistent
|
|
|
|
|
|
+ * ignoring user-specific and hard-to-parse keys but also provides a consistent
|
|
* view for all possible inputs. So if users invoke the
|
|
* view for all possible inputs. So if users invoke the
|
|
- * {@link MapReduceJobPropertiesParser#parseJobProperty()} API with either
|
|
|
|
- * <"mapreduce.job.user.name", "bob"> or <"user.name", "bob">, then the result
|
|
|
|
- * would be a {@link UserName} {@link DataType} wrapping the user-name "bob".
|
|
|
|
|
|
+ * {@link MapReduceJobPropertiesParser#parseJobProperty(String, String)} API
|
|
|
|
+ * with either <"mapreduce.job.user.name", "bob"> or <"user.name", "bob">, then
|
|
|
|
+ * the result would be a {@link UserName} {@link DataType} wrapping the user-name "bob".
|
|
*/
|
|
*/
|
|
@SuppressWarnings("deprecation")
|
|
@SuppressWarnings("deprecation")
|
|
public class MapReduceJobPropertiesParser implements JobPropertyParser {
|
|
public class MapReduceJobPropertiesParser implements JobPropertyParser {
|