org.apache.camel.component.hdfs2
Class HdfsConfiguration

java.lang.Object
  extended by org.apache.camel.component.hdfs2.HdfsConfiguration

public class HdfsConfiguration
extends Object


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

Constructor Detail

HdfsConfiguration

public HdfsConfiguration()
Method Detail

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