public class BigDecimalSplitter extends java.lang.Object implements DBSplitter
Constructor and Description |
---|
BigDecimalSplitter() |
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.
|
public java.util.List<InputSplit> split(org.apache.hadoop.conf.Configuration conf, java.sql.ResultSet results, java.lang.String colName) throws java.sql.SQLException
DBSplitter
split
in interface DBSplitter
java.sql.SQLException
protected java.math.BigDecimal tryDivide(java.math.BigDecimal numerator, java.math.BigDecimal denominator)
Copyright © 2009 The Apache Software Foundation