@InterfaceAudience.Public @InterfaceStability.Evolving public class IntegerSplitter extends Object implements DBSplitter
Constructor and Description |
---|
IntegerSplitter() |
Modifier and Type | Method and Description |
---|---|
List<InputSplit> |
split(Configuration conf,
ResultSet results,
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 List<InputSplit> split(Configuration conf, ResultSet results, String colName) throws SQLException
DBSplitter
split
in interface DBSplitter
SQLException
Copyright © 2021 Apache Software Foundation. All rights reserved.