|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use DateRange | |
|---|---|
| datafu.hourglass.avro | Input and output formats for using Avro in incremental Hadoop jobs. |
| datafu.hourglass.jobs | Incremental Hadoop jobs and some supporting classes. |
| datafu.hourglass.mapreduce | Implementations of mappers, combiners, and reducers used by incremental jobs. |
| Uses of DateRange in datafu.hourglass.avro |
|---|
| Methods in datafu.hourglass.avro that return DateRange | |
|---|---|
static DateRange |
AvroDateRangeMetadata.getOutputFileDateRange(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path)
Reads the date range from the metadata stored in an Avro file. |
| Methods in datafu.hourglass.avro with parameters of type DateRange | |
|---|---|
static void |
AvroDateRangeMetadata.configureOutputDateRange(org.apache.hadoop.conf.Configuration conf,
DateRange dateRange)
Updates the Hadoop configuration so that the Avro files which are written have date range information stored in the metadata. |
| Uses of DateRange in datafu.hourglass.jobs |
|---|
| Methods in datafu.hourglass.jobs that return DateRange | |
|---|---|
DateRange |
PartitionCollapsingExecutionPlanner.getCurrentDateRange()
|
DateRange |
ExecutionPlanner.getDateRange()
Gets the desired input date range to process based on the configuration and available inputs. |
static DateRange |
DateRangePlanner.getDateRange(java.util.Date beginDateOverride,
java.util.Date endDateOverride,
java.util.Collection<java.util.Date> available,
java.lang.Integer daysAgo,
java.lang.Integer numDays)
Determines the date range of inputs which should be processed. |
| Methods in datafu.hourglass.jobs with parameters of type DateRange | |
|---|---|
void |
DateRangeConfigurable.setOutputDateRange(DateRange dateRange)
Sets the date range for the output. |
| Uses of DateRange in datafu.hourglass.mapreduce |
|---|
| Methods in datafu.hourglass.mapreduce with parameters of type DateRange | |
|---|---|
void |
CollapsingCombiner.setOutputDateRange(DateRange dateRange)
|
void |
CollapsingReducer.setOutputDateRange(DateRange dateRange)
|
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||