Package org.springframework.cloud.stream.app.pgcopy.sink

Class PgcopySinkProperties

java.lang.Object
org.springframework.cloud.stream.app.pgcopy.sink.PgcopySinkProperties
@ConfigurationProperties("pgcopy") @Validated public class PgcopySinkProperties extends Object
Used to configure the pgcopy sink module options that are related to writing using the PostgreSQL CopyManager API.
Author:
Thomas Risberg

  • Constructor Details

    • PgcopySinkProperties

      public PgcopySinkProperties()

  • Method Details

    • getTableName

      public String getTableName()

    • setTableName

      public void setTableName(String tableName)

    • getColumns

      public List<String> getColumns()

    • setColumns

      public void setColumns(List<String> columns)

    • getBatchSize

      public int getBatchSize()

    • setBatchSize

      public void setBatchSize(int batchSize)

    • getIdleTimeout

      public long getIdleTimeout()

    • setIdleTimeout

      public void setIdleTimeout(long idleTimeout)

    • getInitialize

      public String getInitialize()

    • setInitialize

      public void setInitialize(String initialize)

    • getFormat

      public PgcopySinkProperties.Format getFormat()

    • setFormat

      public void setFormat(PgcopySinkProperties.Format format)

    • getNullString

      public String getNullString()

    • setNullString

      public void setNullString(String nullString)

    • getDelimiter

      public String getDelimiter()

    • setDelimiter

      public void setDelimiter(String delimiter)

    • getQuote

      public Character getQuote()

    • setQuote

      public void setQuote(Character quote)

    • getEscape

      public Character getEscape()

    • setEscape

      public void setEscape(Character escape)

    • getErrorTable

      public String getErrorTable()

    • setErrorTable

      public void setErrorTable(String errorTable)