datafu.hourglass.jobs
Class AbstractPartitionCollapsingIncrementalJob.Report

java.lang.Object
  datafu.hourglass.jobs.AbstractPartitionCollapsingIncrementalJob.Report

Enclosing class:

AbstractPartitionCollapsingIncrementalJob

public static class AbstractPartitionCollapsingIncrementalJob.Report
extends java.lang.Object

Reports files created and processed for an iteration of the job.

Author:

"Matthew Hayes"

Constructor Summary

AbstractPartitionCollapsingIncrementalJob.Report()

Method Summary

org.apache.hadoop.fs.Path	getCountersPath() Gets the path to the counters file, if one was written.
java.util.List<DatePath>	getInputFiles() Gets new input files that were processed.
java.lang.String	getJobId() Gets the job ID.
java.lang.String	getJobName() Gets the job name.
java.util.List<DatePath>	getOldInputFiles() Gets old input files that were processed.
DatePath	getOutputPath() Gets the path to the output which was produced by the job.
DatePath	getReusedOutput() Gets the output that was reused, if one was reused.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractPartitionCollapsingIncrementalJob.Report

public AbstractPartitionCollapsingIncrementalJob.Report()

Method Detail

getJobName

public java.lang.String getJobName()

Gets the job name.

Returns:

job name

getJobId

public java.lang.String getJobId()

Gets the job ID.

Returns:

job ID

getCountersPath

public org.apache.hadoop.fs.Path getCountersPath()

Gets the path to the counters file, if one was written.

Returns:

counters path

getOutputPath

public DatePath getOutputPath()

Gets the path to the output which was produced by the job.

Returns:

output path

getReusedOutput

public DatePath getReusedOutput()

Gets the output that was reused, if one was reused.

Returns:

reused output path

getInputFiles

public java.util.List<DatePath> getInputFiles()

Gets new input files that were processed. These are files that are within the desired date range.

Returns:

input files

getOldInputFiles

public java.util.List<DatePath> getOldInputFiles()

Gets old input files that were processed. These are files that are before the desired date range and were subtracted from the reused output.

Returns:

output files