Package org.jumpmind.symmetric.io

Class FtpDataWriter

java.lang.Object
org.jumpmind.symmetric.io.FtpDataWriter
All Implemented Interfaces:
IDataResource, IDataWriter
public class FtpDataWriter extends Object implements IDataWriter

  • Field Details

    • server

      protected String server

    • username

      protected String username

    • password

      protected String password

    • protocol

      protected FtpDataWriter.Protocol protocol

    • format

      protected FtpDataWriter.Format format

    • stagingDir

      protected String stagingDir

    • remoteDir

      protected String remoteDir

    • batch

      protected Batch batch

    • table

      protected Table table

    • fileInfoByTable

      protected Map<String,org.jumpmind.symmetric.io.FtpDataWriter.FileInfo> fileInfoByTable

    • manager

      protected org.apache.commons.vfs2.FileSystemManager manager

    • statistics

      protected Map<Batch,Statistics> statistics

  • Constructor Details

    • FtpDataWriter

      public FtpDataWriter()

  • Method Details

    • setRemoteDir

      public void setRemoteDir(String remoteDir)

    • setFormat

      public void setFormat(FtpDataWriter.Format format)

    • setPassword

      public void setPassword(String password)

    • setServer

      public void setServer(String server)

    • setProtocol

      public void setProtocol(FtpDataWriter.Protocol protocol)

    • setUsername

      public void setUsername(String username)

    • setStagingDir

      public void setStagingDir(String stagingDir)

    • open

      public void open(DataContext context)
      Specified by:
      open in interface IDataResource

    • close

      public void close()
      Specified by:
      close in interface IDataResource

    • getStatistics

      public Map<Batch,Statistics> getStatistics()
      Specified by:
      getStatistics in interface IDataResource

    • start

      public void start(Batch batch)
      Specified by:
      start in interface IDataWriter

    • start

      public boolean start(Table table)
      Specified by:
      start in interface IDataWriter

    • write

      public void write(CsvData data)
      Specified by:
      write in interface IDataWriter

    • end

      public void end(Table table)
      Specified by:
      end in interface IDataWriter

    • end

      public void end(Batch batch, boolean inError)
      Specified by:
      end in interface IDataWriter

    • createFile

      protected void createFile(Table table, Batch batch)

    • closeFiles

      protected void closeFiles()

    • deleteFiles

      protected void deleteFiles()

    • sendFiles

      protected void sendFiles()

    • buildUri

      protected String buildUri()

    • printCsvTableHeader

      protected void printCsvTableHeader()

    • printCsvData

      protected void printCsvData(CsvData data)

    • println

      protected void println(String... data)