public class IntegerSplitter extends java.lang.Object implements DBSplitter
Constructor and Description |
---|
IntegerSplitter() |
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.
|
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
Copyright © 2009 The Apache Software Foundation