public class IncrementalColumnRangePartitioner
extends java.lang.Object
implements org.springframework.batch.core.partition.support.Partitioner, org.springframework.batch.core.StepExecutionListener, org.springframework.beans.factory.InitializingBean| 修飾子と型 | フィールドと説明 |
|---|---|
static java.lang.String | BATCH_INCREMENTAL_MAX_ID |
| コンストラクターと説明 |
|---|
IncrementalColumnRangePartitioner() |
| 修飾子と型 | メソッドと説明 |
|---|---|
void | afterPropertiesSet() |
org.springframework.batch.core.ExitStatus | afterStep(org.springframework.batch.core.StepExecution stepExecution) |
void | beforeStep(org.springframework.batch.core.StepExecution stepExecution) |
java.util.Map<java.lang.String,org.springframework.batch.item.ExecutionContext> | partition(int gridSize) 指定された列のデータが均一に分散されていると仮定して、データベーステーブルをパーティション分割します。 |
void | setCheckColumn(java.lang.String checkColumn) |
void | setColumn(java.lang.String column) パーティション化する列の名前。 |
void | setDataSource(javax.sql.DataSource dataSource) データベースに接続するためのデータソース。 |
void | setJobExplorer(org.springframework.batch.core.explore.JobExplorer jobExplorer) |
void | setOverrideValue(java.lang.Long overrideValue) |
void | setPartitions(int partitions) 作成するパーティションの数。 |
void | setTable(java.lang.String table) データが格納されている SQL テーブルの名前。 |
public static final java.lang.String BATCH_INCREMENTAL_MAX_ID
public void setDataSource(javax.sql.DataSource dataSource)
dataSource - DataSourcepublic void setTable(java.lang.String table)
table - テーブルの名前 public void setColumn(java.lang.String column)
column - 列名。public void setPartitions(int partitions)
partitions - パーティションの数。public void setJobExplorer(org.springframework.batch.core.explore.JobExplorer jobExplorer)
public void setCheckColumn(java.lang.String checkColumn)
public void setOverrideValue(java.lang.Long overrideValue)
public java.util.Map<java.lang.String,org.springframework.batch.item.ExecutionContext> partition(int gridSize)
minValue と maxValue が含まれます。org.springframework.batch.core.partition.support.Partitioner 内の partition Partitioner.partition(int)public void beforeStep(org.springframework.batch.core.StepExecution stepExecution)
org.springframework.batch.core.StepExecutionListener 内の beforeStep public org.springframework.batch.core.ExitStatus afterStep(org.springframework.batch.core.StepExecution stepExecution)
org.springframework.batch.core.StepExecutionListener 内の afterStep public void afterPropertiesSet()
throws java.lang.Exceptionorg.springframework.beans.factory.InitializingBean 内の afterPropertiesSet java.lang.Exception