@Test
public void getApexDFSRootDirScheme() throws IOException
{

  Configuration conf = new YarnConfiguration(new Configuration(false));
  conf.set(StramClientUtils.APEX_APP_DFS_ROOT_DIR, "file:/p/q/r");
  conf.setBoolean(StramUserLogin.DT_APP_PATH_IMPERSONATED, false);
  FileSystem fs = FileSystem.newInstance(conf);
  UserGroupInformation testUser = UserGroupInformation.createUserForTesting("testUser1", new String[]{""});
  UserGroupInformation.setLoginUser(testUser);
  Path path = StramClientUtils.getApexDFSRootDir(fs, conf);
  Assert.assertEquals(fs.getHomeDirectory() + "/datatorrent", path.toString());
}