public class StepParserStepFactoryBean<I,O> extends java.lang.Object implements org.springframework.beans.factory.FactoryBean<Step>, org.springframework.beans.factory.BeanNameAware
FactoryBean
は、Step
オブジェクトを作成するためにバッチ名前空間パーサーによって使用されます。<step/>(およびその内部 <tasklet/>)で構成可能なすべてのプロパティを格納します。構成されているプロパティに基づいて、getObject()
メソッドは Step
を生成するための適切なクラスに委譲します。SimpleStepFactoryBean
, FaultTolerantStepFactoryBean
, TaskletStep
コンストラクターと説明 |
---|
StepParserStepFactoryBean() |
修飾子と型 | メソッドと説明 |
---|---|
protected Step | createFaultTolerantStep() |
protected Step | createFlowStep() |
protected Step | createPartitionStep() |
protected Step | createSimpleStep() |
protected TaskletStep | createTaskletStep() |
protected void | enhanceCommonStep(StepBuilderHelper<?> builder) |
protected void | enhanceTaskletStepBuilder(AbstractTaskletStepBuilder<?> builder) |
protected java.lang.Integer | getCommitInterval() |
protected CompletionPolicy | getCompletionPolicy() |
protected FaultTolerantStepBuilder<I, O> | getFaultTolerantStepBuilder(java.lang.String stepName) |
JobRepository | getJobRepository() |
java.lang.String | getName() |
Step | getObject() 提供された構成から Step を作成します。 |
java.lang.Class<TaskletStep> | getObjectType() |
protected PartitionHandler | getPartitionHandler() |
protected SimpleStepBuilder<I, O> | getSimpleStepBuilder(java.lang.String stepName) |
protected StepExecutionAggregator | getStepExecutionAggergator() |
protected Tasklet | getTasklet() |
org.springframework.transaction.PlatformTransactionManager | getTransactionManager() |
protected boolean | hasChunkElement() |
protected boolean | hasPartitionElement() |
protected boolean | hasTasklet() |
protected boolean | isFaultTolerant() |
boolean | isSingleton() |
protected void | registerItemListeners(SimpleStepBuilder<I, O> builder) |
boolean | requiresTransactionManager() |
void | setAllowStartIfComplete(boolean allowStartIfComplete) 初めて成功した場合でも、再起動時にステップを再生する必要があることを示すフラグのパブリック setter。 |
void | setBackOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy) 再試行プロセスに適用されるバックオフポリシー。 |
void | setBeanName(java.lang.String name) Bean name プロパティを設定します。これは、作成時に Step の名前になります。 |
void | setCacheCapacity(int cacheCapacity) 再試行ポリシーのキャッシュ容量用のパブリック setter。 |
protected void | setChunk(SimpleStepBuilder<I, O> builder) |
void | setChunkCompletionPolicy(CompletionPolicy chunkCompletionPolicy) チャンクレベルに適用する CompletionPolicy のパブリック setter。 |
void | setCommitInterval(int commitInterval) コミット間隔を設定します。 |
void | setFlow(Flow flow) |
void | setGridSize(int gridSize) |
void | setHasChunkElement(boolean hasChunkElement) |
void | setIsolation(org.springframework.transaction.annotation.Isolation isolation) |
void | setIsReaderTransactionalQueue(boolean isReaderTransactionalQueue) ロールバック後にアイテムが再表示されるように、リーダーがトランザクション対応(通常は JMS コンシューマー)であることを示すフラグ。 |
void | setItemProcessor(ItemProcessor<? super I,? extends O> itemProcessor) |
void | setItemReader(ItemReader<? extends I> itemReader) |
void | setItemWriter(ItemWriter<? super O> itemWriter) |
void | setJob(Job job) |
void | setJobLauncher(JobLauncher jobLauncher) |
void | setJobParametersExtractor(JobParametersExtractor jobParametersExtractor) |
void | setJobRepository(JobRepository jobRepository) JobRepository のパブリック setter。 |
void | setKeyGenerator(KeyGenerator keyGenerator) 再試行でアイテムを以前に記録されたアイテムと比較するために使用できるキージェネレーター。 |
void | setListeners(java.lang.Object[] listeners) Step に注入するリスナー。 |
void | setName(java.lang.String name) |
void | setNoRollbackExceptionClasses(java.util.Collection<java.lang.Class<? extends java.lang.Throwable>> noRollbackExceptionClasses) 適切な場所で発生した場合にロールバックを引き起こさない例外クラス。 |
void | setPartitioner(Partitioner partitioner) |
void | setPartitionHandler(PartitionHandler partitionHandler) |
void | setPartitionLock(java.util.concurrent.locks.ReentrantLock lock) PartitionCollector と AbstractPartitionAnalyzer の間のパーティションキューへのアクセスを調整するために使用されます |
void | setPartitionQueue(java.util.Queue<java.io.Serializable> queue) |
void | setProcessorTransactional(java.lang.Boolean processorTransactional) プロセッサーがトランザクション対応であることを示すフラグ。この場合、すべてのトランザクションのすべてのアイテムに対して呼び出される必要があります。 |
void | setPropagation(org.springframework.transaction.annotation.Propagation propagation) |
void | setRetryableExceptionClasses(java.util.Map<java.lang.Class<? extends java.lang.Throwable>,java.lang.Boolean> retryableExceptionClasses) 発生したときに項目を再試行する例外クラスのパブリック setter。 |
void | setRetryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache) |
void | setRetryLimit(int retryLimit) 再試行制限のパブリック setter。 |
void | setRetryListeners(org.springframework.retry.RetryListener... retryListeners) RetryListener のパブリック setter。 |
void | setRetryPolicy(org.springframework.retry.RetryPolicy retryPolicy) 例外が発生したときに適用する再試行ポリシー。 |
void | setSkipLimit(int skipLimit) スキップポリシーを決定する制限のパブリック setter。 |
void | setSkippableExceptionClasses(java.util.Map<java.lang.Class<? extends java.lang.Throwable>,java.lang.Boolean> exceptionClasses) 例外クラスのパブリック setter。例外が発生してもジョブはクラッシュしませんが、トランザクションのロールバックが発生し、処理によって例外が発生したアイテムはスキップされます。 |
void | setSkipPolicy(SkipPolicy skipPolicy) スキップポリシーのパブリック setter。 |
void | setStartLimit(int startLimit) ステップの開始を許可する必要がある回数 |
void | setStep(Step step) |
void | setStepExecutionAggregator(StepExecutionAggregator stepExecutionAggregator) |
void | setStreams(ItemStream[] streams) Step に注入するストリーム。 |
void | setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor) TaskExecutor の公開 setter。 |
void | setTasklet(Tasklet tasklet) 使用する構成済み Tasklet 。 |
void | setThrottleLimit(java.lang.Integer throttleLimit) スロットル制限のパブリック setter。 |
void | setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager) |
void | setTransactionTimeout(int transactionTimeout) |
protected void | validateFaultTolerantSettings() フォールトトレラントステップの構築に必要なすべてのコンポーネントが設定されていることを検証します |
public void setPartitionQueue(java.util.Queue<java.io.Serializable> queue)
queue
- PartitionCollector
と PartitionAnalyzer
間の通信に使用される Queue
public void setPartitionLock(java.util.concurrent.locks.ReentrantLock lock)
PartitionCollector
と AbstractPartitionAnalyzer
の間のパーティションキューへのアクセスを調整するために使用されます lock
- パーティションキューへのアクセスに関連してロックされるロック public Step getObject() throws java.lang.Exception
Step
を作成します。org.springframework.beans.factory.FactoryBean<Step>
の getObject
java.lang.Exception
FactoryBean.getObject()
public boolean requiresTransactionManager()
protected void enhanceCommonStep(StepBuilderHelper<?> builder)
builder
- 強化するステップを表す StepBuilderHelper
protected Step createPartitionStep()
protected Step createFaultTolerantStep()
protected FaultTolerantStepBuilder<I,O> getFaultTolerantStepBuilder(java.lang.String stepName)
protected void registerItemListeners(SimpleStepBuilder<I,O> builder)
protected Step createSimpleStep()
protected void setChunk(SimpleStepBuilder<I,O> builder)
protected CompletionPolicy getCompletionPolicy()
protected SimpleStepBuilder<I,O> getSimpleStepBuilder(java.lang.String stepName)
protected TaskletStep createTaskletStep()
TaskletStep
protected void enhanceTaskletStepBuilder(AbstractTaskletStepBuilder<?> builder)
protected Step createFlowStep()
protected void validateFaultTolerantSettings()
protected boolean isFaultTolerant()
public java.lang.Class<TaskletStep> getObjectType()
org.springframework.beans.factory.FactoryBean<Step>
の getObjectType
public boolean isSingleton()
org.springframework.beans.factory.FactoryBean<Step>
の isSingleton
public void setBeanName(java.lang.String name)
Step
の名前になります。org.springframework.beans.factory.BeanNameAware
の setBeanName
BeanNameAware.setBeanName(java.lang.String)
public void setName(java.lang.String name)
name
- 設定する名前 public java.lang.String getName()
public void setFlow(Flow flow)
flow
- 設定する流れ public void setJob(Job job)
public void setJobParametersExtractor(JobParametersExtractor jobParametersExtractor)
public void setJobLauncher(JobLauncher jobLauncher)
public void setPartitioner(Partitioner partitioner)
partitioner
- 設定するパーティショナー public void setStepExecutionAggregator(StepExecutionAggregator stepExecutionAggregator)
stepExecutionAggregator
- 設定する stepExecutionAggregatorprotected StepExecutionAggregator getStepExecutionAggergator()
StepExecutionAggregator
public void setPartitionHandler(PartitionHandler partitionHandler)
partitionHandler
- 設定する partitionHandlerprotected PartitionHandler getPartitionHandler()
PartitionHandler
public void setGridSize(int gridSize)
gridSize
- 設定する gridSizepublic void setStep(Step step)
step
- 設定するステップ public void setAllowStartIfComplete(boolean allowStartIfComplete)
allowStartIfComplete
- 設定する shouldAllowStartIfCompletepublic JobRepository getJobRepository()
public void setJobRepository(JobRepository jobRepository)
JobRepository
のパブリック setter。jobRepository
- ステップで使用される JobRepository
インスタンス。public void setStartLimit(int startLimit)
startLimit
- ステップを開始できる回数を含む整数。public void setTasklet(Tasklet tasklet)
Tasklet
。tasklet
- ステップで使用される Tasklet
インスタンス。protected Tasklet getTasklet()
public org.springframework.transaction.PlatformTransactionManager getTransactionManager()
PlatformTransactionManager
の transactionManager インスタンス。public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)
transactionManager
- 設定するトランザクションマネージャー public void setListeners(java.lang.Object[] listeners)
Step
に注入するリスナー。StepListener
の任意のインスタンスを使用でき、ステップの適切な段階でコールバックを受信します。listeners
- リスナーの配列 public void setNoRollbackExceptionClasses(java.util.Collection<java.lang.Class<? extends java.lang.Throwable>> noRollbackExceptionClasses)
noRollbackExceptionClasses
- 設定する noRollbackExceptionClassespublic void setTransactionTimeout(int transactionTimeout)
transactionTimeout
- 設定する transactionTimeoutpublic void setIsolation(org.springframework.transaction.annotation.Isolation isolation)
isolation
- 設定する分離 public void setPropagation(org.springframework.transaction.annotation.Propagation propagation)
propagation
- 設定する伝播 public void setBackOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy)
backOffPolicy
- 設定する BackOffPolicy
public void setRetryPolicy(org.springframework.retry.RetryPolicy retryPolicy)
retryPolicy
- 設定する RetryPolicy
public void setRetryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache)
retryContextCache
- 設定する RetryContextCache
public void setKeyGenerator(KeyGenerator keyGenerator)
keyGenerator
- 設定する KeyGenerator
public void setCacheCapacity(int cacheCapacity)
MapRetryContextCache
の値です。cacheCapacity
- 設定するキャッシュ容量 (0 より大きい場合は無視)public void setChunkCompletionPolicy(CompletionPolicy chunkCompletionPolicy)
CompletionPolicy
のパブリック setter。このポリシーが完了すると、トランザクションがコミットされます。チャンクサイズが commitInterval プロパティと等しい SimpleCompletionPolicy
がデフォルトです。chunkCompletionPolicy
- 設定する chunkCompletionPolicypublic void setCommitInterval(int commitInterval)
commitInterval
- デフォルトで 1protected java.lang.Integer getCommitInterval()
public void setIsReaderTransactionalQueue(boolean isReaderTransactionalQueue)
isReaderTransactionalQueue
- フラグの値 public void setProcessorTransactional(java.lang.Boolean processorTransactional)
processorTransactional
- 設定する値 public void setRetryLimit(int retryLimit)
retryLimit == 1
です。retryLimit
- 設定する再試行制限。1 以上でなければなりません。public void setSkipLimit(int skipLimit)
skipLimit
- 設定する値。デフォルトは 0(スキップしない)です。public void setSkipPolicy(SkipPolicy skipPolicy)
skipPolicy
- 設定する SkipPolicy
public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)
TaskExecutor
のパブリック setter。これを設定すると、Step
内のチャンク処理を実行するために使用されます。taskExecutor
- 設定する taskExecutorpublic void setThrottleLimit(java.lang.Integer throttleLimit)
TaskExecutorRepeatTemplate.DEFAULT_THROTTLE_LIMIT
です。throttleLimit
- 設定するスロットル制限。public void setItemReader(ItemReader<? extends I> itemReader)
itemReader
- 設定する ItemReader
public void setItemProcessor(ItemProcessor<? super I,? extends O> itemProcessor)
itemProcessor
- 設定する ItemProcessor
public void setItemWriter(ItemWriter<? super O> itemWriter)
itemWriter
- 設定する ItemWriter
public void setRetryListeners(org.springframework.retry.RetryListener... retryListeners)
RetryListener
のパブリック setter。retryListeners
- 設定する RetryListener
public void setSkippableExceptionClasses(java.util.Map<java.lang.Class<? extends java.lang.Throwable>,java.lang.Boolean> exceptionClasses)
exceptionClasses
- キーとして Throwable
を含み、値が Boolean
である Map
は、true の場合、アイテムはスキップされます。public void setRetryableExceptionClasses(java.util.Map<java.lang.Class<? extends java.lang.Throwable>,java.lang.Boolean> retryableExceptionClasses)
retryableExceptionClasses
- 設定する retryableExceptionClassespublic void setStreams(ItemStream[] streams)
Step
に注入するストリーム。ItemStream
の任意のインスタンスを使用でき、ステップの適切な段階でコールバックを受信します。streams
- リスナーの配列 public void setHasChunkElement(boolean hasChunkElement)
hasChunkElement
- ステップに <chunk/> 要素がある場合は true。protected boolean hasChunkElement()
protected boolean hasTasklet()
protected boolean hasPartitionElement()