StagingCommitter extends AbstractS3ACommitter { public static String getUploadUUID(Configuration conf, String jobId) { return conf.getTrimmed( InternalCommitterConstants.FS_S3A_COMMITTER_STAGING_UUID, conf.getTrimmed(SPARK_WRITE_UUID, conf.getTrimmed(SPARK_APP_ID, jobId))); } StagingCommitter(Path outputPath,
      TaskAttemptContext context); @Override String getName(); @Override String toString(); static String getUploadUUID(Configuration conf, String jobId); static String getUploadUUID(Configuration conf, JobID jobId); Boolean useUniqueFilenames(); FileSystem getJobAttemptFileSystem(JobContext context); static Path getJobAttemptPath(JobContext context, Path out); static Path getTaskAttemptPath(TaskAttemptContext context, Path out); Path getCommittedTaskPath(TaskAttemptContext context); @Override Path getTempTaskAttemptPath(TaskAttemptContext context); @Override Path getBaseTaskAttemptPath(TaskAttemptContext context); @Override Path getJobAttemptPath(JobContext context); @Override void setupJob(JobContext context); @Override void cleanupStagingDirs(); @Override void setupTask(TaskAttemptContext context); @Override boolean needsTaskCommit(TaskAttemptContext context); @Override void commitTask(TaskAttemptContext context); @Override void abortTask(TaskAttemptContext context); final ConflictResolution getConflictResolutionMode(
      JobContext context,
      Configuration fsConf); static String getConfictModeOption(JobContext context,
      Configuration fsConf, String defVal); @Override void preCommitJob(
      final JobContext context,
      final ActiveCommit pending); static final String NAME; }
@Test public void testUUIDPropagation() throws Exception { Configuration config = new Configuration(); String jobUUID = addUUID(config); assertEquals("Upload UUID", jobUUID, StagingCommitter.getUploadUUID(config, JOB_ID)); }