org.springframework.cloud.stream.app.hdfs.sink

Class HdfsSinkProperties

java.lang.Object

org.springframework.cloud.stream.app.hdfs.sink.HdfsSinkProperties

@ConfigurationProperties(value="hdfs")
 @Validated
public class HdfsSinkProperties
extends Object

Used to configure those Hdfs Sink module options that are related to connecting to Hdfs.

Author:

Thomas Risberg

Constructor Summary

Constructors

Constructor and Description
HdfsSinkProperties()

Method Summary

Modifier and Type	Method and Description
long	getCloseTimeout()
@Pattern(regexp="(?i)(GZIP|SNAPPY|BZIP2|LZO|SLZO)",message="codec must be one of GZIP, SNAPPY, BZIP2, LZO, or SLZO (case-insensitive)") String	getCodec()
String	getDirectory()
String	getFileExtension()
String	getFileName()
int	getFileOpenAttempts()
long	getFlushTimeout()
String	getFsUri()
long	getIdleTimeout()
String	getInUsePrefix()
String	getInUseSuffix()
String	getPartitionPath()
int	getRollover()
boolean	isEnableSync()
boolean	isFileUuid()
boolean	isOverwrite()
void	setCloseTimeout(long closeTimeout)
void	setCodec(String codec)
void	setDirectory(String directory)
void	setEnableSync(boolean enableSync)
void	setFileExtension(String fileExtension)
void	setFileName(String fileName)
void	setFileOpenAttempts(int fileOpenAttempts)
void	setFileUuid(boolean fileUuid)
void	setFlushTimeout(long flushTimeout)
void	setFsUri(String fsUri)
void	setIdleTimeout(long idleTimeout)
void	setInUsePrefix(String inUsePrefix)
void	setInUseSuffix(String inUseSuffix)
void	setOverwrite(boolean overwrite)
void	setPartitionPath(String partitionPath)
void	setRollover(int rollover)

Methods inherited from class java.lang.Object

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

Constructor Detail

HdfsSinkProperties

public HdfsSinkProperties()

Method Detail

getFsUri

public String getFsUri()

setFsUri

public void setFsUri(String fsUri)

getDirectory

public String getDirectory()

setDirectory

public void setDirectory(String directory)

getFileName

public String getFileName()

setFileName

public void setFileName(String fileName)

getFileExtension

public String getFileExtension()

setFileExtension

public void setFileExtension(String fileExtension)

isFileUuid

public boolean isFileUuid()

setFileUuid

public void setFileUuid(boolean fileUuid)

getCodec

@Pattern(regexp="(?i)(GZIP|SNAPPY|BZIP2|LZO|SLZO)",
         message="codec must be one of GZIP, SNAPPY, BZIP2, LZO, or SLZO (case-insensitive)")
public @Pattern(regexp="(?i)(GZIP|SNAPPY|BZIP2|LZO|SLZO)",message="codec must be one of GZIP, SNAPPY, BZIP2, LZO, or SLZO (case-insensitive)") String getCodec()

setCodec

public void setCodec(String codec)

isOverwrite

public boolean isOverwrite()

setOverwrite

public void setOverwrite(boolean overwrite)

getRollover

public int getRollover()

setRollover

public void setRollover(int rollover)

isEnableSync

public boolean isEnableSync()

setEnableSync

public void setEnableSync(boolean enableSync)

getIdleTimeout

public long getIdleTimeout()

setIdleTimeout

public void setIdleTimeout(long idleTimeout)

getCloseTimeout

public long getCloseTimeout()

setCloseTimeout

public void setCloseTimeout(long closeTimeout)

getFlushTimeout

public long getFlushTimeout()

setFlushTimeout

public void setFlushTimeout(long flushTimeout)

getInUsePrefix

public String getInUsePrefix()

setInUsePrefix

public void setInUsePrefix(String inUsePrefix)

getInUseSuffix

public String getInUseSuffix()

setInUseSuffix

public void setInUseSuffix(String inUseSuffix)

getFileOpenAttempts

public int getFileOpenAttempts()

setFileOpenAttempts

public void setFileOpenAttempts(int fileOpenAttempts)

getPartitionPath

public String getPartitionPath()

setPartitionPath

public void setPartitionPath(String partitionPath)