@ConfigurationProperties(value="hdfs") public class HdfsSinkProperties extends Object
Constructor and Description |
---|
HdfsSinkProperties() |
public String getFsUri()
public void setFsUri(String fsUri)
public String getDirectory()
public void setDirectory(String directory)
public String getFileName()
public void setFileName(String fileName)
public String getFileExtension()
public void setFileExtension(String fileExtension)
public boolean isFileUuid()
public void setFileUuid(boolean fileUuid)
@Pattern(regexp="(?i)(GZIP|SNAPPY|BZIP2|LZO|SLZO)", message="codec must be one of GZIP, SNAPPY, BZIP2, LZO, or SLZO (case-insensitive)") public String getCodec()
public void setCodec(String codec)
public boolean isOverwrite()
public void setOverwrite(boolean overwrite)
public int getRollover()
public void setRollover(int rollover)
public boolean isEnableSync()
public void setEnableSync(boolean enableSync)
public long getIdleTimeout()
public void setIdleTimeout(long idleTimeout)
public long getCloseTimeout()
public void setCloseTimeout(long closeTimeout)
public long getFlushTimeout()
public void setFlushTimeout(long flushTimeout)
public String getInUsePrefix()
public void setInUsePrefix(String inUsePrefix)
public String getInUseSuffix()
public void setInUseSuffix(String inUseSuffix)
public int getFileOpenAttempts()
public void setFileOpenAttempts(int fileOpenAttempts)
public String getPartitionPath()
public void setPartitionPath(String partitionPath)
Copyright © 2016 Pivotal Software, Inc.. All rights reserved.