org.apache.camel.component.hdfs2
Class HdfsConfiguration
java.lang.Object
org.apache.camel.component.hdfs2.HdfsConfiguration
public class HdfsConfiguration
- extends Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
HdfsConfiguration
public HdfsConfiguration()
checkConsumerOptions
public void checkConsumerOptions()
checkProducerOptions
public void checkProducerOptions()
parseURI
public void parseURI(URI uri)
throws URISyntaxException
- Throws:
URISyntaxException
getUri
public URI getUri()
setUri
public void setUri(URI uri)
getHostName
public String getHostName()
setHostName
public void setHostName(String hostName)
getPort
public int getPort()
setPort
public void setPort(int port)
getPath
public String getPath()
setPath
public void setPath(String path)
isOverwrite
public boolean isOverwrite()
setOverwrite
public void setOverwrite(boolean overwrite)
isAppend
public boolean isAppend()
isWantAppend
public boolean isWantAppend()
setAppend
public void setAppend(boolean append)
getBufferSize
public int getBufferSize()
setBufferSize
public void setBufferSize(int bufferSize)
getReplication
public short getReplication()
setReplication
public void setReplication(short replication)
getBlockSize
public long getBlockSize()
setBlockSize
public void setBlockSize(long blockSize)
getFileType
public HdfsFileType getFileType()
setFileType
public void setFileType(HdfsFileType fileType)
getCompressionType
public org.apache.hadoop.io.SequenceFile.CompressionType getCompressionType()
setCompressionType
public void setCompressionType(org.apache.hadoop.io.SequenceFile.CompressionType compressionType)
getCompressionCodec
public HdfsCompressionCodec getCompressionCodec()
setCompressionCodec
public void setCompressionCodec(HdfsCompressionCodec compressionCodec)
setFileSystemType
public void setFileSystemType(HdfsFileSystemType fileSystemType)
getFileSystemType
public HdfsFileSystemType getFileSystemType()
getKeyType
public HdfsWritableFactories.WritableType getKeyType()
setKeyType
public void setKeyType(HdfsWritableFactories.WritableType keyType)
getValueType
public HdfsWritableFactories.WritableType getValueType()
setValueType
public void setValueType(HdfsWritableFactories.WritableType valueType)
setOpenedSuffix
public void setOpenedSuffix(String openedSuffix)
getOpenedSuffix
public String getOpenedSuffix()
setReadSuffix
public void setReadSuffix(String readSuffix)
getReadSuffix
public String getReadSuffix()
setInitialDelay
public void setInitialDelay(long initialDelay)
getInitialDelay
public long getInitialDelay()
setDelay
public void setDelay(long delay)
getDelay
public long getDelay()
setPattern
public void setPattern(String pattern)
getPattern
public String getPattern()
setChunkSize
public void setChunkSize(int chunkSize)
getChunkSize
public int getChunkSize()
setCheckIdleInterval
public void setCheckIdleInterval(int checkIdleInterval)
getCheckIdleInterval
public int getCheckIdleInterval()
getSplitStrategies
public List<HdfsProducer.SplitStrategy> getSplitStrategies()
setSplitStrategy
public void setSplitStrategy(String splitStrategy)
isConnectOnStartup
public boolean isConnectOnStartup()
setConnectOnStartup
public void setConnectOnStartup(boolean connectOnStartup)
getOwner
public String getOwner()
setOwner
public void setOwner(String owner)
Apache Camel