|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
ItemReader
implementations which read
data from database.AbstractMethodInvokingDelegator
ItemReader
implementations which read data from database.StepExecutionDao
implementations.AbstractStep
.RetrySynchronizationManager.clear()
returns null.
ItemReader
implementations.ItemReader
and
ItemStream
.AbstractLineTokenizer
.CompositeItemTransformer
.CompositeItemWriter
DefaultFragmentEventReader
.DefaultTransactionalEventReader
.DelegatingItemReader
DelimitedLineAggregator
Sleeper
implementation that just waits on a local Object.ItemWriter
that will throw an exception when a certain
number of items have been written.EventSequence
ExecutionContextUserSupport
.FileUtils
FixedLengthLineAggregator
FlatFileItemReader
- skip and restart functionality.FlatFileItemReader
- the fundamental item reading functionality.FlatFileItemWriter
Exception cases will be
in separate TestCase classes with different setUp
and
tearDown
methodsFoo
objects.HibernateCursorItemReader
using StatelessSession
.HibernateCursorItemReader
using standard hibernate Session
.HibernateCursorItemReader
using StatelessSession
.IbatisDrivingQueryItemReader
ItemReaderAdapter
.ItemTransformerItemWriter
.ItemWriterAdapter
.JdbcCursorItemReader
NoStartEndDocumentStreamWriter
PropertiesConverter
PropertyExtractingDelegatingItemWriter
SimpleLimitExceptionHandler
SimpleStepFactoryBean
.SkipLimitStepFactoryBean
.SpringValidator
.StaxEventItemReader
.StaxEventItemWriter
.StepExecutionResourceProxy
Step
.StepSupport
.
LineAggregator
interface for testing purposes.AbstractJob.addStep(org.springframework.batch.core.Step)
.
SimpleExportedJobLauncher.afterPropertiesSet()
.
BatchSqlUpdateItemWriter.afterPropertiesSet()
.
HibernateAwareItemWriter.afterPropertiesSet()
.
ItemTransformer
.
HibernateAwareItemWriter.afterPropertiesSet()
.
SimpleExportedJobLauncher.afterPropertiesSet()
.
SimpleExportedJobLauncher.isRunning()
.
ExitStatus.and(boolean)
.
ExitStatus.and(org.springframework.batch.repeat.ExitStatus)
.
ExitStatus.and(org.springframework.batch.repeat.ExitStatus)
.
ExitStatus.and(org.springframework.batch.repeat.ExitStatus)
.
ExitStatus.and(org.springframework.batch.repeat.ExitStatus)
.
ExitStatus.and(org.springframework.batch.repeat.ExitStatus)
.
ThreadStepInterruptionPolicy.checkInterrupted(StepExecution)
.
ThreadStepInterruptionPolicy.checkInterrupted(StepExecution)
.
AbstractTransactionalResourceItemWriter.clear()
.
AbstractTransactionalResourceItemWriter.clear()
.
RepeatContextSupport.registerDestructionCallback(java.lang.String, java.lang.Runnable)
.
RepeatContextSupport.registerDestructionCallback(java.lang.String, java.lang.Runnable)
.
RepeatContextSupport.registerDestructionCallback(java.lang.String, java.lang.Runnable)
.
Entity.equals(java.lang.Object)
.
Entity.equals(java.lang.Object)
.
Entity.equals(java.lang.Object)
.
Entity.equals(java.lang.Object)
.
Entity.equals(java.lang.Object)
.
Entity.equals(java.lang.Object)
.
Entity.equals(java.lang.Object)
.
TaskletAdapter.execute()
.
ExitStatus.ExitStatus(boolean, String)
.
ExitStatus.ExitStatus(boolean, String)
.
ExitStatus.ExitStatus(boolean, String)
.
AbstractTransactionalResourceItemWriter.flush()
.
AbstractTransactionalResourceItemWriter.flush()
.
AbstractTransactionalResourceItemWriter.write(java.lang.Object)
.
StepExecution.getCommitCount()
.
JobExecution.getEndTime()
.
JobExecution.getEndTime()
.
JobExecution.getExitStatus()
.
JobExecution.getExitStatus()
.
JobExecution.getJobId()
.
MapJobRegistry.getJobNames()
.
JobExecution.getJobId()
.
JobExecution.getJobId()
.
JobExecution.getJobId()
.
AbstractJob.getName()
.
JobInstance.getJobName()
.
JobExecution.getStartTime()
.
JobExecution.getStartTime()
.
SimpleExportedJobLauncher.getStatistics()
.
SimpleExportedJobLauncher.getStatistics()
.
BatchStatus.getStatus(java.lang.String)
.
JobExecution.getStatus()
.
JobExecution.getStatus()
.
BatchStatus.getStatus(java.lang.String)
.
BatchStatus.getStatus(java.lang.String)
.
StepExecution.getItemCount()
.
Entity.getVersion()
.
Entity.hashCode()
.
Entity.hashCode()
.
null
or empty.
StepContribution.incrementCommitCount()
.
StepContribution.incrementItemCount()
.
Entity.getVersion()
.
Entity.getVersion()
.
PropertiesConverter
javadoc for more details.
JobExecution.getEndTime()
.
SimpleExportedJobLauncher.isRunning()
.
JobExecution.getEndTime()
.
JobExecution.JobExecution()
.
JobInterruptedException
should be
propagated up.
PassThroughFieldSetMapper.mapLine(org.springframework.batch.item.file.mapping.FieldSet)
.
TaskletAdapter.mapResult(java.lang.Object)
.
TaskletAdapter.mapResult(java.lang.Object)
.
SimpleRetryExceptionHandler.handleException(org.springframework.batch.repeat.RepeatContext, java.lang.Throwable)
.
CompositeStepExecutionListener.beforeStep(StepExecution)
.
CompositeExecutionJobListener.beforeJob(JobExecution)
.
CompositeStepExecutionListener.beforeStep(StepExecution)
.
read
method
read
method
read
method
MapJobRegistry.getJob(java.lang.String)
.
MapJobRegistry.getJob(java.lang.String)
.
SimpleRetryExceptionHandler.handleException(org.springframework.batch.repeat.RepeatContext, java.lang.Throwable)
.
SimpleRetryExceptionHandler.handleException(org.springframework.batch.repeat.RepeatContext, java.lang.Throwable)
.
SimpleExportedJobLauncher.run(java.lang.String)
.
SimpleExportedJobLauncher.run(java.lang.String)
.
SimpleExportedJobLauncher.run(java.lang.String)
.
LineAggregatorItemTransformer.setAggregator(org.springframework.batch.item.file.transform.LineAggregator)
.
AbstractJob.setBeanName(java.lang.String)
.
AbstractJob.setBeanName(java.lang.String)
.
RecursiveCollectionItemTransformer.setDelegate(org.springframework.batch.item.transform.ItemTransformer)
.
RecursiveCollectionItemTransformer.setDelegate(org.springframework.batch.item.transform.ItemTransformer)
.
RecursiveCollectionItemTransformer.setDelegate(org.springframework.batch.item.transform.ItemTransformer)
.
CompositeExecutionJobListener.register(org.springframework.batch.core.JobExecutionListener)
.
CompositeStepExecutionListener.register(org.springframework.batch.core.StepExecutionListener)
.
CompositeRepeatListener#register(RepeatListener)
.
CompositeExecutionJobListener.setListeners(org.springframework.batch.core.JobExecutionListener[])
.
CompositeStepExecutionListener.setListeners(org.springframework.batch.core.StepExecutionListener[])
.
CompositeRepeatListener#setListeners(RepeatListener[])
.
AbstractJob.setRestartable(boolean)
.
JobSupport.setStartLimit(int)
.
AbstractJob.setSteps(java.util.List)
.
JobExecution.JobExecution()
.
JobExecution.JobExecution()
.
StepExecutionListener.afterStep(StepExecution)
causes step to fail.
StepExecutionListener.afterStep(StepExecution)
causes step to fail.
SimpleExportedJobLauncher.stop()
.
BatchStatus.toString()
.
LineAggregatorItemTransformer.transform(java.lang.Object)
.
RecursiveCollectionItemTransformer.transform(java.lang.Object)
.
RecursiveCollectionItemTransformer.transform(java.lang.Object)
.
RecursiveCollectionItemTransformer.transform(java.lang.Object)
.
RecursiveCollectionItemTransformer.transform(java.lang.Object)
.
LineAggregatorItemTransformer.transform(java.lang.Object)
.
PassThroughFieldSetMapper.mapItem(java.lang.Object)
.
PassThroughFieldSetMapper.mapItem(java.lang.Object)
.
PassThroughFieldSetMapper.mapItem(java.lang.Object)
.
MapJobRegistry.unregister(String)
.
ValidationException
is thrown
AbstractTransactionalResourceItemWriter.write(java.lang.Object)
.
AbstractTransactionalResourceItemWriter.write(java.lang.Object)
.
AbstractTransactionalResourceItemWriter.flush()
.
AbstractTransactionalResourceItemWriter.write(java.lang.Object)
.
write(String[], LineDescriptor)
method
write(String)
method
write(String)
method
write(String)
method
write(String)
method
write(String)
method
write(String)
method
UnmarshallingEventReaderDeserializer
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |