org.springframework.xd.greenplum.config

Class GPFDistSinkOptionsMetadata

java.lang.Object

org.springframework.xd.greenplum.config.GPFDistSinkOptionsMetadata

public class GPFDistSinkOptionsMetadata
extends java.lang.Object

Config options for gpfdist sink.

Author:

Janne Valkealahti

Constructor Summary

Constructors

Constructor and Description
GPFDistSinkOptionsMetadata()

Method Summary

Methods

Modifier and Type	Method and Description
int	getBatchCount()
int	getBatchPeriod()
int	getBatchTimeout()
java.lang.Character	getColumnDelimiter()
java.lang.String	getControlFile()
java.lang.String	getDbHost()
java.lang.String	getDbName()
java.lang.String	getDbPassword()
int	getDbPort()
java.lang.String	getDbUser()
java.lang.String	getDelimiter()
int	getFlushCount()
int	getFlushTime()
java.lang.String	getMatchColumns()
java.lang.String	getMode()
int	getPort()
int	getRateInterval()
java.lang.String	getSqlAfter()
java.lang.String	getSqlBefore()
java.lang.String	getTable()
java.lang.String	getUpdateColumns()
void	setBatchCount(int batchCount)
void	setBatchPeriod(int batchPeriod)
void	setBatchTimeout(int batchTimeout)
void	setColumnDelimiter(java.lang.Character columnDelimiter)
void	setControlFile(java.lang.String controlFile)
void	setDbHost(java.lang.String dbHost)
void	setDbName(java.lang.String dbName)
void	setDbPassword(java.lang.String dbPassword)
void	setDbPort(int dbPort)
void	setDbUser(java.lang.String dbUser)
void	setDelimiter(java.lang.String delimiter)
void	setFlushCount(int flushCount)
void	setFlushTime(int flushTime)
void	setMatchColumns(java.lang.String matchColumns)
void	setMode(java.lang.String mode)
void	setPort(int port)
void	setRateInterval(int rateInterval)
void	setSqlAfter(java.lang.String sqlAfter)
void	setSqlBefore(java.lang.String sqlBefore)
void	setTable(java.lang.String table)
void	setUpdateColumns(java.lang.String updateColumns)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GPFDistSinkOptionsMetadata

public GPFDistSinkOptionsMetadata()

Method Detail

getPort

public int getPort()

setPort

public void setPort(int port)

getFlushCount

public int getFlushCount()

setFlushCount

public void setFlushCount(int flushCount)

getFlushTime

public int getFlushTime()

setFlushTime

public void setFlushTime(int flushTime)

getBatchTimeout

public int getBatchTimeout()

setBatchTimeout

public void setBatchTimeout(int batchTimeout)

getBatchPeriod

public int getBatchPeriod()

setBatchPeriod

public void setBatchPeriod(int batchPeriod)

getBatchCount

public int getBatchCount()

setBatchCount

public void setBatchCount(int batchCount)

getDbName

public java.lang.String getDbName()

setDbName

public void setDbName(java.lang.String dbName)

getDbUser

public java.lang.String getDbUser()

setDbUser

public void setDbUser(java.lang.String dbUser)

getDbPassword

public java.lang.String getDbPassword()

setDbPassword

public void setDbPassword(java.lang.String dbPassword)

getDbHost

public java.lang.String getDbHost()

setDbHost

public void setDbHost(java.lang.String dbHost)

getDbPort

public int getDbPort()

setDbPort

public void setDbPort(int dbPort)

getControlFile

public java.lang.String getControlFile()

setControlFile

public void setControlFile(java.lang.String controlFile)

getDelimiter

public java.lang.String getDelimiter()

setDelimiter

public void setDelimiter(java.lang.String delimiter)

getColumnDelimiter

public java.lang.Character getColumnDelimiter()

setColumnDelimiter

public void setColumnDelimiter(java.lang.Character columnDelimiter)

getMode

public java.lang.String getMode()

setMode

public void setMode(java.lang.String mode)

getUpdateColumns

public java.lang.String getUpdateColumns()

setUpdateColumns

public void setUpdateColumns(java.lang.String updateColumns)

getMatchColumns

public java.lang.String getMatchColumns()

setMatchColumns

public void setMatchColumns(java.lang.String matchColumns)

getTable

public java.lang.String getTable()

setTable

public void setTable(java.lang.String table)

getRateInterval

public int getRateInterval()

setRateInterval

public void setRateInterval(int rateInterval)

getSqlBefore

public java.lang.String getSqlBefore()

setSqlBefore

public void setSqlBefore(java.lang.String sqlBefore)

getSqlAfter

public java.lang.String getSqlAfter()

setSqlAfter

public void setSqlAfter(java.lang.String sqlAfter)