org.apache.hadoop.mapreduce.lib.db

Class DateSplitter

java.lang.Object

org.apache.hadoop.mapreduce.lib.db.IntegerSplitter

org.apache.hadoop.mapreduce.lib.db.DateSplitter

All Implemented Interfaces:

DBSplitter

Direct Known Subclasses:

OracleDateSplitter

public class DateSplitter
extends IntegerSplitter

Implement DBSplitter over date/time values. Make use of logic from IntegerSplitter, since date/time are just longs in Java.

Constructor Summary

Constructors

Constructor and Description
DateSplitter()

Method Summary

Methods

Modifier and Type	Method and Description
protected java.lang.String	dateToString(java.util.Date d) Given a Date 'd', format it as a string for use in a SQL date comparison operation.
java.util.List<InputSplit>	split(org.apache.hadoop.conf.Configuration conf, java.sql.ResultSet results, java.lang.String colName) Given a ResultSet containing one record (and already advanced to that record) with two columns (a low value, and a high value, both of the same type), determine a set of splits that span the given values.

Methods inherited from class java.lang.Object

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

Constructor Detail

DateSplitter

public DateSplitter()

Method Detail

split

public java.util.List<InputSplit> split(org.apache.hadoop.conf.Configuration conf,
                               java.sql.ResultSet results,
                               java.lang.String colName)
                                 throws java.sql.SQLException

Description copied from interface: DBSplitter

Given a ResultSet containing one record (and already advanced to that record) with two columns (a low value, and a high value, both of the same type), determine a set of splits that span the given values.

Specified by:

split in interface DBSplitter

Overrides:

split in class IntegerSplitter

Throws:

java.sql.SQLException

dateToString

protected java.lang.String dateToString(java.util.Date d)

Given a Date 'd', format it as a string for use in a SQL date comparison operation.

Parameters:

d - the date to format.

Returns:

the string representing this date in SQL with any appropriate quotation characters, etc.