类 AbstractFileItemWriter<T>

字段详细资料

• DEFAULT_TRANSACTIONAL

  public static final boolean DEFAULT_TRANSACTIONAL

  另请参阅:

  常量字段值

• logger

  protected static final org.apache.commons.logging.Log logger

• DEFAULT_LINE_SEPARATOR

  public static final java.lang.String DEFAULT_LINE_SEPARATOR

• DEFAULT_CHARSET

  public static final java.lang.String DEFAULT_CHARSET

  另请参阅:

  常量字段值

• state

  protected AbstractFileItemWriter.OutputState state

• shouldDeleteIfExists

  protected boolean shouldDeleteIfExists

• lineSeparator

  protected java.lang.String lineSeparator

• append

  protected boolean append

构造器详细资料

• AbstractFileItemWriter

  public AbstractFileItemWriter()

方法详细资料

• setForceSync

  public void setForceSync​(boolean forceSync)

  Flag to indicate that changes should be force-synced to disk on flush. Defaults to false, which means that even with a local disk changes could be lost if the OS crashes in between a write and a cache flush. Setting to true may result in slower performance for usage patterns involving many frequent writes.

  参数:

  forceSync - the flag value to set

• setLineSeparator

  public void setLineSeparator​(java.lang.String lineSeparator)

  Public setter for the line separator. Defaults to the System property line.separator.

  参数:

  lineSeparator - the line separator to set

• setResource

  public void setResource​(org.springframework.core.io.Resource resource)

  Setter for resource. Represents a file that can be written.

  指定者:

  setResource 在接口中 ResourceAwareItemWriterItemStream<T>

  参数:

  resource - the resource to be written to

• setEncoding

  public void setEncoding​(java.lang.String newEncoding)

  Sets encoding for output template.

  参数:

  newEncoding - String containing the encoding to be used for the writer.

• setShouldDeleteIfExists

  public void setShouldDeleteIfExists​(boolean shouldDeleteIfExists)

  Flag to indicate that the target file should be deleted if it already exists, otherwise it will be created. Defaults to true, so no appending except on restart. If set to false and appendAllowed is also false then there will be an exception when the stream is opened to prevent existing data being potentially corrupted.

  参数:

  shouldDeleteIfExists - the flag value to set

• setAppendAllowed

  public void setAppendAllowed​(boolean append)

  Flag to indicate that the target file should be appended if it already exists. If this flag is set then the flag shouldDeleteIfExists is automatically set to false, so that flag should not be set explicitly. Defaults value is false.

  参数:

  append - the flag value to set

• setShouldDeleteIfEmpty

  public void setShouldDeleteIfEmpty​(boolean shouldDeleteIfEmpty)

  Flag to indicate that the target file should be deleted if no lines have been written (other than header and footer) on close. Defaults to false.

  参数:

  shouldDeleteIfEmpty - the flag value to set

• setSaveState

  public void setSaveState​(boolean saveState)

  Set the flag indicating whether or not state should be saved in the provided ExecutionContext during the ItemStream call to update. Setting this to false means that it will always start at the beginning on a restart.

  参数:

  saveState - if true, state will be persisted

• setHeaderCallback

  public void setHeaderCallback​(FlatFileHeaderCallback headerCallback)

  headerCallback will be called before writing the first item to file. Newline will be automatically appended after the header is written.

  参数:

  headerCallback - FlatFileHeaderCallback to generate the header

• setFooterCallback

  public void setFooterCallback​(FlatFileFooterCallback footerCallback)

  footerCallback will be called after writing the last item to file, but before the file is closed.

  参数:

  footerCallback - FlatFileFooterCallback to generate the footer

• setTransactional

  public void setTransactional​(boolean transactional)

  Flag to indicate that writing to the buffer should be delayed if a transaction is active. Defaults to true.

  参数:

  transactional - true if writing to buffer should be delayed.

• write

  public void write​(java.util.List<? extends T> items)
             throws java.lang.Exception

  Writes out a string followed by a "new line", where the format of the new line separator is determined by the underlying operating system.

  指定者:

  write 在接口中 ItemWriter<T>

  参数:

  items - list of items to be written to output stream

  抛出:

  java.lang.Exception - if an error occurs while writing items to the output stream

• doWrite

  protected abstract java.lang.String doWrite​(java.util.List<? extends T> items)

  Write out a string of items followed by a "new line", where the format of the new line separator is determined by the underlying operating system.

  参数:

  items - to be written

  返回:

  written lines

• close

  public void close()

  从类复制的说明: ItemStreamSupport
  No-op.

  指定者:

  close 在接口中 ItemStream

  覆盖:

  close 在类中 ItemStreamSupport

  另请参阅:

  ItemStream.close()

• open

  public void open​(ExecutionContext executionContext)
            throws ItemStreamException

  Initialize the reader. This method may be called multiple times before close is called.

  指定者:

  open 在接口中 ItemStream

  覆盖:

  open 在类中 ItemStreamSupport

  参数:

  executionContext - current step's ExecutionContext. Will be the executionContext from the last run of the step on a restart.

  抛出:

  ItemStreamException

  另请参阅:

  ItemStream.open(ExecutionContext)

• update

  public void update​(ExecutionContext executionContext)

  从类复制的说明: ItemStreamSupport
  Return empty ExecutionContext.

  指定者:

  update 在接口中 ItemStream

  覆盖:

  update 在类中 ItemStreamSupport

  参数:

  executionContext - to be updated

  另请参阅:

  ItemStream.update(ExecutionContext)

• getOutputState

  protected AbstractFileItemWriter.OutputState getOutputState()