org.springframework.xd.batch.jdbc

Class ColumnRangePartitioner

java.lang.Object

org.springframework.xd.batch.jdbc.ColumnRangePartitioner

All Implemented Interfaces:

org.springframework.batch.core.partition.support.Partitioner

public class ColumnRangePartitioner
extends java.lang.Object
implements org.springframework.batch.core.partition.support.Partitioner

A simple partitioner for a range of values of a column in a database table. Works best if the values are uniformly distributed (e.g. auto-generated primary key values).

Author:

Dave Syer, Thomas Risberg

Constructor Summary

Constructors

Constructor and Description
ColumnRangePartitioner()

Method Summary

Methods

Modifier and Type	Method and Description
java.util.Map<java.lang.String,org.springframework.batch.item.ExecutionContext>	partition(int gridSize) Partition a database table assuming that the data in the column specified are uniformly distributed.
void	setColumn(java.lang.String column) The name of the column to partition.
void	setDataSource(javax.sql.DataSource dataSource) The data source for connecting to the database.
void	setPartitions(int partitions) The number of partitions to create.
void	setTable(java.lang.String table) The name of the SQL table the data are in.

Methods inherited from class java.lang.Object

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

Constructor Detail

ColumnRangePartitioner

public ColumnRangePartitioner()

Method Detail

setDataSource

public void setDataSource(javax.sql.DataSource dataSource)

The data source for connecting to the database.

Parameters:

dataSource - a DataSource

setTable

public void setTable(java.lang.String table)

The name of the SQL table the data are in.

Parameters:

table - the name of the table

setColumn

public void setColumn(java.lang.String column)

The name of the column to partition.

Parameters:

column - the column name.

setPartitions

public void setPartitions(int partitions)

The number of partitions to create.

Parameters:

partitions - the number of partitions.

partition

public java.util.Map<java.lang.String,org.springframework.batch.item.ExecutionContext> partition(int gridSize)

Partition a database table assuming that the data in the column specified are uniformly distributed. The execution context values will have keys minValue and maxValue specifying the range of values to consider in each partition.

Specified by:

partition in interface org.springframework.batch.core.partition.support.Partitioner

See Also:

Partitioner.partition(int)