public class HadoopMRUtil extends Object
Constructor and Description |
---|
HadoopMRUtil() |
Modifier and Type | Method and Description |
---|---|
static Map<Path,Path> |
addToClassPath(Configuration config,
List<String> classpath)
Add to class path.
|
static boolean |
hasReducer(JobConf jobConf) |
static String |
readStateFromDistCache(JobConf jobConf,
String id,
String kind) |
static String |
writeStateToDistCache(JobConf conf,
String id,
String kind,
String stepState) |
public HadoopMRUtil()
public static String writeStateToDistCache(JobConf conf, String id, String kind, String stepState)
public static String readStateFromDistCache(JobConf jobConf, String id, String kind) throws IOException
IOException
public static Map<Path,Path> addToClassPath(Configuration config, List<String> classpath)
config
- the configclasspath
- the classpathpublic static boolean hasReducer(JobConf jobConf)
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.