datafu.hourglass.jobs

Class AbstractPartitionPreservingIncrementalJob.Report

java.lang.Object

datafu.hourglass.jobs.AbstractPartitionPreservingIncrementalJob.Report

Enclosing class:

AbstractPartitionPreservingIncrementalJob

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

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

Constructor Summary

Constructors

Constructor and Description
AbstractPartitionPreservingIncrementalJob.Report()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.fs.Path	getCountersPath() Gets the path to the counters file, if one was written.
java.util.List<DatePath>	getInputFiles() Gets 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>	getOutputFiles() Gets the output files that were produced by the job.

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractPartitionPreservingIncrementalJob.Report

public AbstractPartitionPreservingIncrementalJob.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

getInputFiles

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

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

Returns:

new input files

getOutputFiles

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

Gets the output files that were produced by the job.

Returns:

old input files