クラス StepParserStepFactoryBean<I,O>

メソッドの詳細

• getObject

  public Step getObject() throws ExceptionSE

  提供された構成から Step を作成します。

  次で指定:

  インターフェース org.springframework.beans.factory.FactoryBean<I> の getObject 

  例外:

  ExceptionSE

  関連事項:

  • FactoryBean.getObject()

• requiresTransactionManager

  public boolean requiresTransactionManager()

  現在、TaskletStep 以外のすべてのステップ実装は AbstractStep のインスタンスであり、トランザクションマネージャーは必要ありません。

• enhanceCommonStep

  protected void enhanceCommonStep(StepBuilderHelper<?> builder)

  提供された StepBuilderHelper からの属性でステップを拡張します。

  パラメーター:

  builder - 強化するステップを表す StepBuilderHelper

• createPartitionStep

  protected Step createPartitionStep()

  パーティション Step を作成します。

  戻り値:

  Step

• createFaultTolerantStep

  protected Step createFaultTolerantStep()

  フォールトトレラント Step を作成します。

  戻り値:

  Step

• getFaultTolerantStepBuilder

  protected FaultTolerantStepBuilder<I,O> getFaultTolerantStepBuilder(StringSE stepName)

  新しい FaultTolerantStepBuilder を作成します。

  パラメーター:

  stepName - 作成されたビルダーによって使用されるステップの名前。

  戻り値:

  FaultTolerantStepBuilder

• registerItemListeners

  protected void registerItemListeners(SimpleStepBuilder<I,O> builder)

• createSimpleStep

  protected Step createSimpleStep()

  新しい TaskletStep を作成します。

  戻り値:

  TaskletStep

• setChunk

  protected void setChunk(SimpleStepBuilder<I,O> builder)

• getCompletionPolicy

  protected CompletionPolicy getCompletionPolicy()

• getSimpleStepBuilder

  protected SimpleStepBuilder<I,O> getSimpleStepBuilder(StringSE stepName)

• createTaskletStep

  protected TaskletStep createTaskletStep()

  新しい TaskletStep を作成します。

  戻り値:

  新しい TaskletStep

• enhanceTaskletStepBuilder

  protected void enhanceTaskletStepBuilder(AbstractTaskletStepBuilder<?> builder)

  提供時の Bean で確立された値を使用して、AbstractTaskletStepBuilder の状態を設定します。

  パラメーター:

  builder - 変更する AbstractTaskletStepBuilder。

• createFlowStep

  protected Step createFlowStep()

  新しい FlowStep を作成します。

  戻り値:

  FlowStep

• validateFaultTolerantSettings

  protected void validateFaultTolerantSettings()

  フォールトトレラントステップを構築するために必要なすべてのコンポーネントが設定されていることを検証します。

• isFaultTolerant

  protected boolean isFaultTolerant()

  ステップにフォールトトレランスを必要とするコンポーネントがあるかどうかを示します。

  戻り値:

  ステップがフォールトトレランスを必要とするコンポーネントで構成されている場合は、true。

• getObjectType

  public ClassSE<TaskletStep> getObjectType()

  次で指定:

  インターフェース org.springframework.beans.factory.FactoryBean<I> の getObjectType 

• isSingleton

  public boolean isSingleton()

  次で指定:

  インターフェース org.springframework.beans.factory.FactoryBean<I> の isSingleton 

• setBeanName

  public void setBeanName(StringSE name)

  Bean name プロパティを設定します。これは、作成時に Step の名前になります。

  次で指定:

  インターフェース org.springframework.beans.factory.BeanNameAware の setBeanName 

  関連事項:

  • BeanNameAware.setBeanName(java.lang.String)

• setName

  public void setName(StringSE name)

  パラメーター:

  name - 設定する名前

• getName

  public StringSE getName()

• setFlow

  public void setFlow(Flow flow)

  パラメーター:

  flow - 設定する流れ

• setJob

  public void setJob(Job job)

• setJobParametersExtractor

  public void setJobParametersExtractor(JobParametersExtractor jobParametersExtractor)

• setJobLauncher

  public void setJobLauncher(JobLauncher jobLauncher)

• setPartitioner

  public void setPartitioner(Partitioner partitioner)

  パラメーター:

  partitioner - 設定するパーティショナー

• setStepExecutionAggregator

  public void setStepExecutionAggregator(StepExecutionAggregator stepExecutionAggregator)

  パラメーター:

  stepExecutionAggregator - 設定する stepExecutionAggregator

• getStepExecutionAggergator

  protected StepExecutionAggregator getStepExecutionAggergator()

  戻り値:

  現在のステップの StepExecutionAggregator

• setPartitionHandler

  public void setPartitionHandler(PartitionHandler partitionHandler)

  パラメーター:

  partitionHandler - 設定する partitionHandler

• getPartitionHandler

  protected PartitionHandler getPartitionHandler()

  戻り値:

  現在のステップの PartitionHandler

• setGridSize

  public void setGridSize(int gridSize)

  パラメーター:

  gridSize - 設定する gridSize

• setStep

  public void setStep(Step step)

  パラメーター:

  step - 設定するステップ

• setAllowStartIfComplete

  public void setAllowStartIfComplete(boolean allowStartIfComplete)

  初めて成功した場合でも、再起動時にステップを再生する必要があることを示すフラグのパブリック setter。

  パラメーター:

  allowStartIfComplete - 設定する shouldAllowStartIfComplete

• getJobRepository

  public JobRepository getJobRepository()

  戻り値:

  ジョブリポジトリ

• setJobRepository

  public void setJobRepository(JobRepository jobRepository)

  JobRepository のパブリック setter。

  パラメーター:

  jobRepository - ステップで使用される JobRepository インスタンス。

• setStartLimit

  public void setStartLimit(int startLimit)

  ステップの開始を許可する回数。

  パラメーター:

  startLimit - ステップを開始できる回数を含む整数。

• setTasklet

  public void setTasklet(Tasklet tasklet)

  使用する構成済み Tasklet。

  パラメーター:

  tasklet - ステップで使用される Tasklet インスタンス。

• getTasklet

  protected Tasklet getTasklet()

• getTransactionManager

  public org.springframework.transaction.PlatformTransactionManager getTransactionManager()

  戻り値:

  ステップで使用される PlatformTransactionManager のインスタンス。

• setTransactionManager

  public void setTransactionManager(org.springframework.transaction.PlatformTransactionManager transactionManager)

  パラメーター:

  transactionManager - 設定するトランザクションマネージャー

• setListeners

  public void setListeners(ObjectSE[] listeners)

  Step に注入するリスナー。StepListener の任意のインスタンスを使用でき、ステップの適切な段階でコールバックを受け取ります。

  パラメーター:

  listeners - リスナーの配列

• setNoRollbackExceptionClasses

  public void setNoRollbackExceptionClasses(CollectionSE<ClassSE<? extends ThrowableSE>> noRollbackExceptionClasses)

  適切な場所で発生した場合にロールバックを引き起こさない例外クラス。

  パラメーター:

  noRollbackExceptionClasses - 設定する noRollbackExceptionClasses

• setTransactionTimeout

  public void setTransactionTimeout(int transactionTimeout)

  パラメーター:

  transactionTimeout - 設定する transactionTimeout

• setIsolation

  public void setIsolation(org.springframework.transaction.annotation.Isolation isolation)

  パラメーター:

  isolation - 設定するアイソレーション

• setPropagation

  public void setPropagation(org.springframework.transaction.annotation.Propagation propagation)

  パラメーター:

  propagation - 設定する伝搬

• setBackOffPolicy

  public void setBackOffPolicy(org.springframework.retry.backoff.BackOffPolicy backOffPolicy)

  再試行プロセスに適用されるバックオフポリシー。

  パラメーター:

  backOffPolicy - 設定する BackOffPolicy 

• setRetryPolicy

  public void setRetryPolicy(org.springframework.retry.RetryPolicy retryPolicy)

  例外が発生したときに適用する再試行ポリシー。これが指定されている場合、再試行制限と再試行可能な例外は無視されます。

  パラメーター:

  retryPolicy - 設定する RetryPolicy 

• setRetryContextCache

  public void setRetryContextCache(org.springframework.retry.policy.RetryContextCache retryContextCache)

  パラメーター:

  retryContextCache - 設定する RetryContextCache 

• setKeyGenerator

  public void setKeyGenerator(KeyGenerator keyGenerator)

  再試行でアイテムを以前に記録されたアイテムと比較するために使用できるキージェネレーター。リーダーがトランザクションキューである場合にのみ使用されます。

  パラメーター:

  keyGenerator - 設定する KeyGenerator

• setCacheCapacity

  public void setCacheCapacity(int cacheCapacity)

  再試行ポリシーのキャッシュの容量のパブリック setter。指定された容量よりも多くのアイテムがある場合、ステップはスキップまたは回復されずに失敗し、例外がスローされます。これにより、アイテムの同一性の問題によって生成される不注意な無限ループを防ぐことができます。
  
  デフォルト値は、ほとんどの目的に対して十分に高いはずです。シングルスレッドステップで制限に違反するには、通常、1 つのトランザクションでこれだけ多くの失敗が発生する必要があります。デフォルトは MapRetryContextCache の値です。
  

  パラメーター:

  cacheCapacity - 設定するキャッシュ容量 (0 より大きい場合は無視)

• setChunkCompletionPolicy

  public void setChunkCompletionPolicy(CompletionPolicy chunkCompletionPolicy)

  チャンクレベルに適用される CompletionPolicy のパブリック setter。このポリシーが完了を決定すると、トランザクションがコミットされます。デフォルトは、commitInterval プロパティと等しいチャンクサイズを持つ SimpleCompletionPolicy です。

  パラメーター:

  chunkCompletionPolicy - 設定する chunkCompletionPolicy。

• setCommitInterval

  public void setCommitInterval(int commitInterval)

  コミット間隔を設定します。これまたは chunkCompletionPolicy のいずれかを設定しますが、両方を設定することはできません。

  パラメーター:

  commitInterval - デフォルトで 1

• getCommitInterval

  protected IntegerSE getCommitInterval()

  戻り値:

  コミット間隔。

• setIsReaderTransactionalQueue

  public void setIsReaderTransactionalQueue(boolean isReaderTransactionalQueue)

  ロールバック後に項目が再提示されるように、リーダーがトランザクション対応 (通常は JMS コンシューマー) であることを示すフラグ。デフォルトは false で、リーダーは転送専用であると見なされます。

  パラメーター:

  isReaderTransactionalQueue - フラグの値

• setProcessorTransactional

  public void setProcessorTransactional(BooleanSE processorTransactional)

  プロセッサーがトランザクション対応であることを示すフラグ。その場合、すべてのトランザクションのすべてのアイテムに対して呼び出す必要があります。false の場合、ロールバックの場合にトランザクション間でプロセッサーの結果をキャッシュできます。

  パラメーター:

  processorTransactional - 設定する値

• setRetryLimit

  public void setRetryLimit(int retryLimit)

  再試行制限のパブリック setter。各項目は、この制限まで再試行できます。この制限には、アイテムを処理するための最初の試行が含まれることに注意してください。デフォルトでは retryLimit == 1.

  パラメーター:

  retryLimit - 設定する再試行制限。1 以上である必要があります。

• setSkipLimit

  public void setSkipLimit(int skipLimit)

  スキップポリシーを決定する制限のパブリック setter。この値が正の場合、チャンク処理での例外により項目がスキップされ、制限に達するまで例外は伝播されません。ゼロの場合、すべての例外がチャンクから伝播され、ステップが中止されます。

  パラメーター:

  skipLimit - 設定する値。デフォルトは 0 (スキップしない) です。

• setSkipPolicy

  public void setSkipPolicy(SkipPolicy skipPolicy)

  スキップポリシーのパブリック setter。この値が設定されている場合、スキップ制限とスキップ可能な例外は無視されます。

  パラメーター:

  skipPolicy - 設定する SkipPolicy。

• setTaskExecutor

  public void setTaskExecutor(org.springframework.core.task.TaskExecutor taskExecutor)

  TaskExecutor のパブリック setter。これが設定されている場合、Step 内でチャンク処理を実行するために使用されます。

  パラメーター:

  taskExecutor - 設定する taskExecutor。

• setThrottleLimit

  @DeprecatedSE(since="5.0", forRemoval=true) public void setThrottleLimit(IntegerSE throttleLimit)

  非推奨、削除予定: この API 要素は、将来のバージョンで削除される可能性があります。

  5.0 以降、6.0 で削除予定。いずれにせよ、この API はエンドユーザーを対象としたものではありません。これは、XML 名前空間パーサーによってのみ使用されます。

  スロットル制限のパブリック setter。これにより、並行処理のためにキューに入れられるタスクの数が制限され、スレッドプールがオーバーロードになるのを防ぎます。デフォルトは TaskExecutorRepeatTemplate.DEFAULT_THROTTLE_LIMIT です。

  パラメーター:

  throttleLimit - 設定するスロットル制限。

• setItemReader

  public void setItemReader(ItemReader<? extends I> itemReader)

  パラメーター:

  itemReader - 設定する ItemReader。

• setItemProcessor

  public void setItemProcessor(ItemProcessor<? super I,? extends O> itemProcessor)

  パラメーター:

  itemProcessor - 設定する ItemProcessor。

• setItemWriter

  public void setItemWriter(ItemWriter<? super O> itemWriter)

  パラメーター:

  itemWriter - 設定する ItemWriter。

• setRetryListeners

  public void setRetryListeners(org.springframework.retry.RetryListener... retryListeners)

  RetryListener インスタンスのパブリック setter。

  パラメーター:

  retryListeners - 設定する RetryListener インスタンス。

• setSkippableExceptionClasses

  public void setSkippableExceptionClasses(MapSE<ClassSE<? extends ThrowableSE>,BooleanSE> exceptionClasses)

  例外クラスのパブリック setter が発生すると、ジョブはクラッシュしませんが、トランザクションロールバックが発生します。処理が例外を引き起こした項目はスキップされます。

  パラメーター:

  exceptionClasses - ThrowableSE インスタンスをキーとして、BooleanSE インスタンスを値として含む MapSE。true の場合、項目はスキップされます。

• setRetryableExceptionClasses

  public void setRetryableExceptionClasses(MapSE<ClassSE<? extends ThrowableSE>,BooleanSE> retryableExceptionClasses)

  発生時に項目を再試行する例外クラスのパブリック setter。

  パラメーター:

  retryableExceptionClasses - 設定する retryableExceptionClasses。

• setStreams

  public void setStreams(ItemStream[] streams)

  Step に注入するストリーム。ItemStream の任意のインスタンスを使用でき、ステップの適切な段階でコールバックを受け取ります。

  パラメーター:

  streams - リスナーの配列

• setHasChunkElement

  public void setHasChunkElement(boolean hasChunkElement)

  パラメーター:

  hasChunkElement - ステップに <chunk/> 要素がある場合は true。

• hasChunkElement

  protected boolean hasChunkElement()

  戻り値:

  定義されたステップに <chunk/> 要素がある場合は true。

• hasTasklet

  protected boolean hasTasklet()

  戻り値:

  定義されたステップに <tasklet/> 要素がある場合は true。

• hasPartitionElement

  protected boolean hasPartitionElement()

  戻り値:

  定義されたステップに <partition/> 要素がある場合は true。