类 CompositeItemStream
- java.lang.Object
- org.springframework.batch.item.support.CompositeItemStream
- 所有已实现的接口:
ItemStream
public class CompositeItemStream extends java.lang.Object implements ItemStream
SimpleItemStream
that delegates to a list of other streams.- 作者:
- Dave Syer
构造器概要
构造器 构造器 说明 CompositeItemStream()
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 void
close()
Broadcast the call to close.void
open(ExecutionContext executionContext)
Broadcast the call to open.void
register(ItemStream stream)
Register aItemStream
as one of the interesting providers under the provided key.void
setStreams(ItemStream[] streams)
Public setter for theItemStream
s.void
update(ExecutionContext executionContext)
Simple aggregateExecutionContext
provider for the contributions registered under the given key.
构造器详细资料
CompositeItemStream
public CompositeItemStream()
方法详细资料
setStreams
public void setStreams(ItemStream[] streams)
Public setter for theItemStream
s.- 参数:
streams
- array ofItemStream
.
register
public void register(ItemStream stream)
Register aItemStream
as one of the interesting providers under the provided key.- 参数:
stream
- an instance ofItemStream
to be added to the list of streams.
update
public void update(ExecutionContext executionContext)
Simple aggregateExecutionContext
provider for the contributions registered under the given key.- 指定者:
update
在接口中ItemStream
- 参数:
executionContext
- to be updated- 另请参阅:
ItemStream.update(ExecutionContext)
close
public void close() throws ItemStreamException
Broadcast the call to close.- 指定者:
close
在接口中ItemStream
- 抛出:
ItemStreamException
- thrown if one of theItemStream
s in the list fails to close. This is a sequential operation so all itemStreams in the list after the one that failed to close will remain open.
open
public void open(ExecutionContext executionContext) throws ItemStreamException
Broadcast the call to open.- 指定者:
open
在接口中ItemStream
- 参数:
executionContext
- current step'sExecutionContext
. Will be the executionContext from the last run of the step on a restart.- 抛出:
ItemStreamException
- thrown if one of theItemStream
s in the list fails to open. This is a sequential operation so all itemStreams in the list after the one that failed to open will not be opened.