类 CompositeItemStream
- java.lang.Object
- org.springframework.batch.item.support.CompositeItemStream
- 所有已实现的接口:
ItemStream
public class CompositeItemStream extends java.lang.Object implements ItemStream
SimpleItemStreamthat delegates to a list of other streams.- 作者:
- Dave Syer
构造器概要
构造器 构造器 说明 CompositeItemStream()
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 voidclose()Broadcast the call to close.voidopen(ExecutionContext executionContext)Broadcast the call to open.voidregister(ItemStream stream)Register aItemStreamas one of the interesting providers under the provided key.voidsetStreams(ItemStream[] streams)Public setter for theItemStreams.voidupdate(ExecutionContext executionContext)Simple aggregateExecutionContextprovider for the contributions registered under the given key.
构造器详细资料
CompositeItemStream
public CompositeItemStream()
方法详细资料
setStreams
public void setStreams(ItemStream[] streams)
Public setter for theItemStreams.- 参数:
streams- array ofItemStream.
register
public void register(ItemStream stream)
Register aItemStreamas one of the interesting providers under the provided key.- 参数:
stream- an instance ofItemStreamto be added to the list of streams.
update
public void update(ExecutionContext executionContext)
Simple aggregateExecutionContextprovider 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 theItemStreams 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 theItemStreams 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.