org.apache.streams.hdfs

Class HdfsWriterConfiguration

java.lang.Object

org.apache.streams.converter.LineReadWriteConfiguration

org.apache.streams.hdfs.HdfsConfiguration

org.apache.streams.hdfs.HdfsWriterConfiguration

All Implemented Interfaces:

Serializable

@Generated(value="org.jsonschema2pojo")
public class HdfsWriterConfiguration
extends HdfsConfiguration
implements Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HdfsWriterConfiguration.Compression

Nested classes/interfaces inherited from class org.apache.streams.hdfs.HdfsConfiguration

HdfsConfiguration.Scheme

Constructor Summary

Constructors

Constructor and Description
HdfsWriterConfiguration()

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object other)
Map<String,Object>	getAdditionalProperties()
HdfsWriterConfiguration.Compression	getCompression() compression
Long	getLinesPerFile() Lines Per File
String	getWriterFilePrefix() File Prefix
String	getWriterPath() Path
int	hashCode()
void	setAdditionalProperty(String name, Object value)
void	setCompression(HdfsWriterConfiguration.Compression compression) compression
void	setLinesPerFile(Long linesPerFile) Lines Per File
void	setWriterFilePrefix(String writerFilePrefix) File Prefix
void	setWriterPath(String writerPath) Path
String	toString()
HdfsWriterConfiguration	withAdditionalProperty(String name, Object value)
HdfsWriterConfiguration	withCompression(HdfsWriterConfiguration.Compression compression)
HdfsWriterConfiguration	withLinesPerFile(Long linesPerFile)
HdfsWriterConfiguration	withWriterFilePrefix(String writerFilePrefix)
HdfsWriterConfiguration	withWriterPath(String writerPath)

Methods inherited from class org.apache.streams.hdfs.HdfsConfiguration

getHost, getPassword, getPath, getPort, getScheme, getUser, setHost, setPassword, setPath, setPort, setScheme, setUser, withHost, withPassword, withPath, withPort, withScheme, withUser

Methods inherited from class org.apache.streams.converter.LineReadWriteConfiguration

getEncoding, getFieldDelimiter, getFields, getLineDelimiter, setEncoding, setFieldDelimiter, setFields, setLineDelimiter, withEncoding, withFieldDelimiter, withFields, withLineDelimiter

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

HdfsWriterConfiguration

public HdfsWriterConfiguration()

Method Detail

getWriterPath

@BeanProperty(value="writerPath")
public String getWriterPath()

Path

Returns:

The writerPath

setWriterPath

@BeanProperty(value="writerPath")
public void setWriterPath(String writerPath)

Path

Parameters:

writerPath - The writerPath

withWriterPath

public HdfsWriterConfiguration withWriterPath(String writerPath)

getWriterFilePrefix

@BeanProperty(value="writerFilePrefix")
public String getWriterFilePrefix()

File Prefix

Returns:

The writerFilePrefix

setWriterFilePrefix

@BeanProperty(value="writerFilePrefix")
public void setWriterFilePrefix(String writerFilePrefix)

File Prefix

Parameters:

writerFilePrefix - The writerFilePrefix

withWriterFilePrefix

public HdfsWriterConfiguration withWriterFilePrefix(String writerFilePrefix)

getLinesPerFile

@BeanProperty(value="linesPerFile")
public Long getLinesPerFile()

Lines Per File

Returns:

The linesPerFile

setLinesPerFile

@BeanProperty(value="linesPerFile")
public void setLinesPerFile(Long linesPerFile)

Lines Per File

Parameters:

linesPerFile - The linesPerFile

withLinesPerFile

public HdfsWriterConfiguration withLinesPerFile(Long linesPerFile)

getCompression

@BeanProperty(value="compression")
public HdfsWriterConfiguration.Compression getCompression()

compression

Returns:

The compression

setCompression

@BeanProperty(value="compression")
public void setCompression(HdfsWriterConfiguration.Compression compression)

compression

Parameters:

compression - The compression

withCompression

public HdfsWriterConfiguration withCompression(HdfsWriterConfiguration.Compression compression)

toString

public String toString()

Overrides:

toString in class HdfsConfiguration

getAdditionalProperties

@BeanProperty(name="*")
public Map<String,Object> getAdditionalProperties()

Overrides:

getAdditionalProperties in class HdfsConfiguration

setAdditionalProperty

@BeanProperty(name="*")
public void setAdditionalProperty(String name,
                                                          Object value)

Overrides:

setAdditionalProperty in class HdfsConfiguration

withAdditionalProperty

public HdfsWriterConfiguration withAdditionalProperty(String name,
                                                      Object value)

Overrides:

withAdditionalProperty in class HdfsConfiguration

hashCode

public int hashCode()

Overrides:

hashCode in class HdfsConfiguration

equals

public boolean equals(Object other)

Overrides:

equals in class HdfsConfiguration