Uses of Package
datafu.hourglass.jobs

Packages that use datafu.hourglass.jobs

datafu.hourglass.jobs	Incremental Hadoop jobs and some supporting classes.
datafu.hourglass.mapreduce	Implementations of mappers, combiners, and reducers used by incremental jobs.

Classes in datafu.hourglass.jobs used by datafu.hourglass.jobs

AbstractJob
Base class for Hadoop jobs.

AbstractNonIncrementalJob.BaseCombiner
Combiner base class for AbstractNonIncrementalJob.

AbstractNonIncrementalJob.BaseMapper
Mapper base class for AbstractNonIncrementalJob.

AbstractNonIncrementalJob.BaseReducer
Reducer base class for AbstractNonIncrementalJob.

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

AbstractPartitionCollapsingIncrementalJob
An IncrementalJob that consumes partitioned input data and collapses the partitions to produce a single output.

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

AbstractPartitionPreservingIncrementalJob
An IncrementalJob that consumes partitioned input data and produces output data having the same partitions.

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

ExecutionPlanner
Base class for execution planners.

IncrementalJob
Base class for incremental jobs.

Setup
Used as a callback by PartitionCollapsingIncrementalJob and PartitionPreservingIncrementalJob to provide configuration settings for the Hadoop job.

StagedOutputJob
A derivation of Job that stages its output in another location and only moves it to the final destination if the job completes successfully.

TimeBasedJob
Base class for Hadoop jobs that consume time-partitioned data.

Classes in datafu.hourglass.jobs used by datafu.hourglass.mapreduce

DateRangeConfigurable
An interface for an object with a configurable output date range.