/**
?*?Licensed?to?the?Apache?Software?Foundation?（ASF）?under?one
?*?or?more?contributor?license?agreements.??See?the?NOTICE?file
?*?distributed?with?this?work?for?additional?information
?*?regarding?copyright?ownership.??The?ASF?licenses?this?file
?*?to?you?under?the?Apache?License?Version?2.0?（the
?*?“License“）;?you?may?not?use?this?file?except?in?compliance
?*?with?the?License.??You?may?obtain?a?copy?of?the?License?at
?*
?*?????http://www.apache.org/licenses/LICENSE-2.0
?*
?*?Unless?required?by?applicable?law?or?agreed?to?in?writing?software
?*?distributed?under?the?License?is?distributed?on?an?“AS?IS“?BASIS
?*?WITHOUT?WARRANTIES?OR?CONDITIONS?OF?ANY?KIND?either?express?or?implied.
?*?See?the?License?for?the?specific?language?governing?permissions?and
?*?limitations?under?the?License.
?*/

package?org.apache.hadoop;

import?java.io.IOException;

import?org.apache.hadoop.fs.FileSystem;
import?org.apache.hadoop.fs.Path;
import?org.apache.hadoop.mapred.FileOutputFormat;
import?org.apache.hadoop.mapred.JobConf;
import?org.apache.hadoop.mapred.JobContext;
import?org.apache.hadoop.mapred.OutputCommitter;
import?org.apache.hadoop.mapred.TaskAttemptContext;

public?class?CustomOutputCommitter?extends?OutputCommitter?{

??public?static?final?String?JOB_SETUP_FILE_NAME?=?“_job_setup“;
??public?static?final?String?JOB_COMMIT_FILE_NAME?=?“_job_commit“;
??public?static?final?String?JOB_ABORT_FILE_NAME?=?“_job_abort“;
??public?static?final?String?TASK_SETUP_FILE_NAME?=?“_task_setup“;
??public?static?final?String?TASK_ABORT_FILE_NAME?=?“_task_abort“;
??public?static?final?String?TASK_COMMIT_FILE_NAME?=?“_task_commit“;

??@Override
??public?void?setupJob（JobContext?jobContext）?throws?IOException?{
????writeFile（jobContext.getJobConf（）?JOB_SETUP_FILE_NAME）;
??}

??@Override
??public?void?commitJob（JobContext?jobContext）?throws?IOException?{
????super.commitJob（jobContext）;
????writeFile（jobContext.getJobConf（）?JOB_COMMIT_FILE_NAME）;
??}

??@Override
??public?void?abortJob（JobContext?jobContext?int?status）?
??throws?IOException?{
????super.abortJob（jobContext?status）;
????writeFile（jobContext.getJobConf（）?JOB_ABORT_FILE_NAME）;
??}
??
??@Override
??public?void?setupTask（TaskAttemptContext?taskContext）?throws?IOException?{
????writeFile（taskContext.getJobConf（）?TASK_SETUP_FILE_NAME）;
??}

??@Override
??public?boolean?needsTaskCommit（TaskAttemptContext?taskContext）
??????throws?IOException?{
????return?true;
??}

??@Override
??public?void?commitTask（TaskAttemptContext?taskContext）?throws?IOException?{
????writeFile（taskContext.getJobConf（）?TASK_COMMIT_FILE_NAME）;
??}

??@Override
??public?void?abortTask（TaskAttemptContext?taskContext）?throws?IOException?{
????writeFile（taskContext.getJobConf（）?TASK_ABORT_FILE_NAME）;
??}

??private?void?writeFile（JobConf?conf??String?filename）?throws?IOException?{
????System.out.println（“writing?file?----“?+?filename）;
????Path?outputPath?=?FileOutputFormat.getOutputPath（conf）;
????FileSystem?fs?=?outputPath.getFileSys

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2018-07-11?09:28??org\
?????目錄???????????0??2018-07-11?09:28??org\apache\
?????目錄???????????0??2018-07-11?09:28??org\apache\hadoop\
?????目錄???????????0??2018-07-11?09:28??org\apache\hadoop\ant\
?????目錄???????????0??2018-07-11?09:28??org\apache\hadoop\ant\condition\
?????文件????????2042??2018-07-11?09:28??org\apache\hadoop\ant\condition\DfsbaseConditional.java
?????文件?????????983??2018-07-11?09:28??org\apache\hadoop\ant\condition\DfsExists.java
?????文件?????????982??2018-07-11?09:28??org\apache\hadoop\ant\condition\DfsIsDir.java
?????文件?????????984??2018-07-11?09:28??org\apache\hadoop\ant\condition\DfsZeroLen.java
?????文件????????6855??2018-07-11?09:28??org\apache\hadoop\ant\DfsTask.java
?????目錄???????????0??2018-07-11?09:28??org\apache\hadoop\classification\
?????文件????????2633??2018-07-11?09:28??org\apache\hadoop\classification\InterfaceAudience.java
?????文件????????2483??2018-07-11?09:28??org\apache\hadoop\classification\InterfaceStability.java
?????目錄???????????0??2018-07-11?09:28??org\apache\hadoop\classification\tools\
?????文件????????2194??2018-07-11?09:28??org\apache\hadoop\classification\tools\ExcludePrivateAnnotationsJDiffDoclet.java
?????文件????????2239??2018-07-11?09:28??org\apache\hadoop\classification\tools\ExcludePrivateAnnotationsStandardDoclet.java
?????文件????????2517??2018-07-11?09:28??org\apache\hadoop\classification\tools\IncludePublicAnnotationsStandardDoclet.java
?????文件????????1038??2018-07-11?09:28??org\apache\hadoop\classification\tools\package-info.java
?????文件????????9326??2018-07-11?09:28??org\apache\hadoop\classification\tools\RootDocProcessor.java
?????文件????????2565??2018-07-11?09:28??org\apache\hadoop\classification\tools\StabilityOptions.java
?????目錄???????????0??2018-07-11?09:28??org\apache\hadoop\conf\
?????文件????????1296??2018-07-11?09:28??org\apache\hadoop\conf\Configurable.java
?????文件??????100519??2018-07-11?09:28??org\apache\hadoop\conf\Configuration.java
?????文件????????1553??2018-07-11?09:28??org\apache\hadoop\conf\Configured.java
?????文件????????3482??2018-07-11?09:28??org\apache\hadoop\conf\ConfServlet.java
?????文件?????????868??2018-07-11?09:28??org\apache\hadoop\conf\package.html
?????文件????????1987??2018-07-11?09:28??org\apache\hadoop\conf\Reconfigurable.java
?????文件????????8311??2018-07-11?09:28??org\apache\hadoop\conf\Reconfigurablebase.java
?????文件????????2879??2018-07-11?09:28??org\apache\hadoop\conf\ReconfigurationException.java
?????文件????????8898??2018-07-11?09:28??org\apache\hadoop\conf\ReconfigurationServlet.java
?????文件????????2103??2018-07-11?09:28??org\apache\hadoop\conf\ReconfigurationTaskStatus.java
............此處省略4596個文件信息