public static Framework getFramework(Configuration jobConf) {
    // Check if this is a pig job
    boolean isPig = jobConf.get(Constants.PIG_CONF_KEY) != null;
    if (isPig) {
      return Framework.PIG;
    } else {
      String flowId = jobConf.get(Constants.CASCADING_FLOW_ID_CONF_KEY);
      if ((flowId == null) || (flowId.length() == 0)) {
        return Framework.NONE;
      } else {
        return Framework.SCALDING;
      }
    }
  }
public static Framework getFramework ( Configuration jobConf ) { boolean isPig = jobConf . get ( Constants . PIG_CONF_KEY ) != null ; if ( isPig ) { return Framework . PIG ; } else { String flowId = jobConf . get ( Constants . CASCADING_FLOW_ID_CONF_KEY ) ; if ( ( flowId == null ) || ( flowId . length ( ) == 0 ) ) { return Framework . NONE ; } else { return Framework . SCALDING ; } } }
@param jobConf
a given job configuration.
@return which framerwork was used to launch that configuration.