CountTableRows MapReduceジョブの結果

セキュア・ストアに対して実行しているか、非セキュア・ストアに対して実行しているかにかかわらず、このジョブからの出力は、エラーが発生していないとすると次のようになります。

...
INFO  [main] mapreduce.Job (Job.java:monitorAndPrintJob(1344)) 
    - Running job: job_1409172332346_0024
INFO  [main] mapreduce.Job (Job.java:monitorAndPrintJob(1372)) 
    -  map 0% reduce 0% INFO  [main] mapreduce.Job 
    (Job.java:monitorAndPrintJob(1372)) 
    -  map 26% reduce 0%
INFO  [main] mapreduce.Job (Job.java:monitorAndPrintJob(1372)) 
    -  map 56% reduce 0%
INFO  [main] mapreduce.Job (Job.java:monitorAndPrintJob(1372)) 
    -  map 100% reduce 0% INFO  [main] mapreduce.Job 
    (Job.java:monitorAndPrintJob(1383)) 
    - Job job_1409172332346_0024 completed successfully
INFO  [main] mapreduce.Job (Job.java:monitorAndPrintJob(1390)) 
    - Counters: 49
    File System Counters
        FILE: Number of bytes read=2771
        FILE: Number of bytes written=644463
        FILE: Number of read operations=0
        FILE: Number of large read operations=0
        FILE: Number of write operations=0
        HDFS: Number of bytes read=2660
        HDFS: Number of bytes written=32
        HDFS: Number of read operations=15
        HDFS: Number of large read operations=0
        HDFS: Number of write operations=2
    Job Counters 
        Launched map tasks=6
        Launched reduce tasks=1
        Rack-local map tasks=6
        Total time spent by all maps in occupied slots (ms)=136868
        Total time spent by all reduces in occupied slots (ms)=2103
        Total time spent by all map tasks (ms)=136868
        Total time spent by all reduce tasks (ms)=2103
        Total vcore-seconds taken by all map tasks=136868
        Total vcore-seconds taken by all reduce tasks=2103
        Total megabyte-seconds taken by all map tasks=140152832
        Total megabyte-seconds taken by all reduce tasks=2153472
    Map-Reduce Framework
        Map input records=79
        Map output bytes=2607
        Map output materialized bytes=2801
        Input split bytes=2660
        Combine input records=0
        Combine output records=0
        Reduce input groups=1
        Reduce shuffle bytes=2801
        Reduce input records=79
        Reduce output records=1
        Spilled Records=158
        Shuffled Maps =6
        Failed Shuffles=0
        Merged Map outputs=6
        GC time elapsed (ms)=549
        CPU time spent (ms)=9460
        Physical memory (bytes) snapshot=1888358400
        Virtual memory (bytes) snapshot=6424895488
        Total committed heap usage (bytes)=1409286144
    Shuffle Errors
        BAD_ID=0
        CONNECTION=0
        IO_ERROR=0
        WRONG_LENGTH=0
        WRONG_MAP=0
        WRONG_REDUCE=0
    File Input Format Counters 
        Bytes Read=0
    File Output Format Counters 
        Bytes Written=32

ジョブの結果を確認して、プログラムが表の行数を正しくカウントしたことを検証するには、Hadoop CLIを使用してHDFSにあるMapReduceの結果ファイルの内容を表示します。その場合は、Hadoopクラスタのアクセス・ノードのコマンドラインで次のように入力します。

hadoop fs -cat \
    /user/example-user/CountTableRows/vehicleTable/<000N>/part-r-00000

<000N>トークンは、ジョブの実行時に使用した値に置き換えます。表に79行が移入されていたと仮定すると、ジョブが成功した場合の出力は次のようになります。

/type/make/model/class  79

この/type/make/model/classは、vehicleTableのPrimaryKeyを構成するフィールドの名前です。また、79は表の行数です。