org.apache.hadoop.mapreduce.lib.db

Class BigDecimalSplitter

java.lang.Object

org.apache.hadoop.mapreduce.lib.db.BigDecimalSplitter

All Implemented Interfaces:

DBSplitter

Direct Known Subclasses:

TextSplitter

public class BigDecimalSplitter
extends java.lang.Object
implements DBSplitter

Implement DBSplitter over BigDecimal values.

Constructor Summary

Constructors

Constructor and Description
BigDecimalSplitter()

Method Summary

Methods

Modifier and Type	Method and Description
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.
protected java.math.BigDecimal	tryDivide(java.math.BigDecimal numerator, java.math.BigDecimal denominator) Divide numerator by denominator.

Methods inherited from class java.lang.Object

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

Constructor Detail

BigDecimalSplitter

public BigDecimalSplitter()

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

Throws:

java.sql.SQLException

tryDivide

protected java.math.BigDecimal tryDivide(java.math.BigDecimal numerator,
                             java.math.BigDecimal denominator)

Divide numerator by denominator. If impossible in exact mode, use rounding.