Skip navigation links
Camel :: HDFS2 2.23.2.fuse-750029-redhat-00001
A C D G H I N O P R S V W 

A

append(HdfsOutputStream, Object, Object, TypeConverter) - Method in enum org.apache.camel.component.hdfs2.HdfsFileType
 
append(Object, Object, TypeConverter) - Method in class org.apache.camel.component.hdfs2.HdfsOutputStream
 

C

checkConsumerOptions() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
checkProducerOptions() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
close() - Method in class org.apache.camel.component.hdfs2.HdfsInputStream
 
close() - Method in class org.apache.camel.component.hdfs2.HdfsOutputStream
 
copyBytes(InputStream, OutputStream, int, boolean) - Static method in enum org.apache.camel.component.hdfs2.HdfsFileType
 
create(Object, TypeConverter, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsBooleanWritableFactory
 
create(Object, TypeConverter, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsBytesWritableFactory
 
create(Object, TypeConverter, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsByteWritableFactory
 
create(Object, TypeConverter, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsDoubleWritableFactory
 
create(Object, TypeConverter, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsFloatWritableFactory
 
create(Object, TypeConverter, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsIntWritableFactory
 
create(Object, TypeConverter, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsLongWritableFactory
 
create(Object, TypeConverter, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsNullWritableFactory
 
create(Object, TypeConverter, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsObjectWritableFactory
 
create(Object, TypeConverter, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsTextWritableFactory
 
createConsumer(Processor) - Method in class org.apache.camel.component.hdfs2.HdfsEndpoint
 
createEndpoint(String, String, Map<String, Object>) - Method in class org.apache.camel.component.hdfs2.HdfsComponent
 
createInputStream(String, HdfsConfiguration) - Method in enum org.apache.camel.component.hdfs2.HdfsFileType
 
createInputStream(String, HdfsConfiguration) - Static method in class org.apache.camel.component.hdfs2.HdfsInputStream
 
createOutputStream(String, HdfsConfiguration) - Method in enum org.apache.camel.component.hdfs2.HdfsFileType
 
createOutputStream(String, HdfsConfiguration) - Static method in class org.apache.camel.component.hdfs2.HdfsOutputStream
 
createProducer() - Method in class org.apache.camel.component.hdfs2.HdfsEndpoint
 

D

DEFAULT_BLOCKSIZE - Static variable in class org.apache.camel.component.hdfs2.HdfsConstants
 
DEFAULT_BUFFERSIZE - Static variable in class org.apache.camel.component.hdfs2.HdfsConstants
 
DEFAULT_CHECK_IDLE_INTERVAL - Static variable in class org.apache.camel.component.hdfs2.HdfsConstants
 
DEFAULT_CODEC - Static variable in class org.apache.camel.component.hdfs2.HdfsConstants
 
DEFAULT_COMPRESSIONTYPE - Static variable in class org.apache.camel.component.hdfs2.HdfsConstants
 
DEFAULT_CONSUMER_INITIAL_DELAY - Static variable in class org.apache.camel.component.hdfs2.HdfsConsumer
 
DEFAULT_DELAY - Static variable in class org.apache.camel.component.hdfs2.HdfsConstants
 
DEFAULT_OPENED_SUFFIX - Static variable in class org.apache.camel.component.hdfs2.HdfsConstants
 
DEFAULT_PATTERN - Static variable in class org.apache.camel.component.hdfs2.HdfsConstants
 
DEFAULT_PORT - Static variable in class org.apache.camel.component.hdfs2.HdfsConstants
 
DEFAULT_READ_SUFFIX - Static variable in class org.apache.camel.component.hdfs2.HdfsConstants
 
DEFAULT_REPLICATION - Static variable in class org.apache.camel.component.hdfs2.HdfsConstants
 
DEFAULT_SEGMENT_PREFIX - Static variable in class org.apache.camel.component.hdfs2.HdfsConstants
 
doPoll() - Method in class org.apache.camel.component.hdfs2.HdfsConsumer
 
doStart() - Method in class org.apache.camel.component.hdfs2.HdfsConsumer
 
doStart() - Method in class org.apache.camel.component.hdfs2.HdfsProducer
 
doStop() - Method in class org.apache.camel.component.hdfs2.HdfsProducer
 

G

getActualPath() - Method in class org.apache.camel.component.hdfs2.HdfsInputStream
 
getActualPath() - Method in class org.apache.camel.component.hdfs2.HdfsOutputStream
 
getBlockSize() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getBufferSize() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getCheckIdleInterval() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getChunkSize() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getChunkSize() - Method in class org.apache.camel.component.hdfs2.HdfsInputStream
 
getCodec() - Method in enum org.apache.camel.component.hdfs2.HdfsCompressionCodec
 
getCompressionCodec() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getCompressionType() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getConf() - Method in class org.apache.camel.component.hdfs2.HdfsInfo
 
getConfig() - Method in class org.apache.camel.component.hdfs2.HdfsEndpoint
 
getEndpoint() - Method in class org.apache.camel.component.hdfs2.HdfsConsumer
 
getEndpoint() - Method in class org.apache.camel.component.hdfs2.HdfsProducer
 
getFileSystem() - Method in class org.apache.camel.component.hdfs2.HdfsInfo
 
getFileSystemType() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getFileType() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getHdfsPath(HdfsConfiguration) - Method in enum org.apache.camel.component.hdfs2.HdfsFileSystemType
 
getHostName() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getIn() - Method in class org.apache.camel.component.hdfs2.HdfsInputStream
 
getKeyType() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getLastAccess() - Method in class org.apache.camel.component.hdfs2.HdfsOutputStream
 
getNumOfReadBytes() - Method in class org.apache.camel.component.hdfs2.HdfsInputStream
 
getNumOfReadMessages() - Method in class org.apache.camel.component.hdfs2.HdfsInputStream
 
getNumOfWrittenBytes() - Method in class org.apache.camel.component.hdfs2.HdfsOutputStream
 
getNumOfWrittenMessages() - Method in class org.apache.camel.component.hdfs2.HdfsOutputStream
 
getOpenedSuffix() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getOut() - Method in class org.apache.camel.component.hdfs2.HdfsOutputStream
 
getOwner() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getPath() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getPath() - Method in class org.apache.camel.component.hdfs2.HdfsInfo
 
getPattern() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getPort() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getReadSuffix() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getReplication() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getSplitStrategies() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getSplitStrategy() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getType() - Method in class org.apache.camel.component.hdfs2.HdfsProducer.SplitStrategy
 
getUri() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getValue() - Method in class org.apache.camel.component.hdfs2.HdfsProducer.SplitStrategy
 
getValueType() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
getWritableClass() - Method in enum org.apache.camel.component.hdfs2.WritableType
 

H

HDFS_CLOSE - Static variable in class org.apache.camel.component.hdfs2.HdfsConstants
 
HdfsActivator - Class in org.apache.camel.component.hdfs2.osgi
 
HdfsActivator() - Constructor for class org.apache.camel.component.hdfs2.osgi.HdfsActivator
 
HdfsBooleanWritableFactory() - Constructor for class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsBooleanWritableFactory
 
HdfsBytesWritableFactory() - Constructor for class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsBytesWritableFactory
 
HdfsByteWritableFactory() - Constructor for class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsByteWritableFactory
 
HdfsComponent - Class in org.apache.camel.component.hdfs2
 
HdfsComponent() - Constructor for class org.apache.camel.component.hdfs2.HdfsComponent
 
HdfsComponent(CamelContext) - Constructor for class org.apache.camel.component.hdfs2.HdfsComponent
 
HdfsCompressionCodec - Enum in org.apache.camel.component.hdfs2
 
HdfsConfiguration - Class in org.apache.camel.component.hdfs2
 
HdfsConfiguration() - Constructor for class org.apache.camel.component.hdfs2.HdfsConfiguration
 
HdfsConstants - Class in org.apache.camel.component.hdfs2
 
HdfsConsumer - Class in org.apache.camel.component.hdfs2
 
HdfsConsumer(HdfsEndpoint, Processor, HdfsConfiguration) - Constructor for class org.apache.camel.component.hdfs2.HdfsConsumer
 
HdfsDoubleWritableFactory() - Constructor for class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsDoubleWritableFactory
 
HdfsEndpoint - Class in org.apache.camel.component.hdfs2
For reading/writing from/to an HDFS filesystem using Hadoop 2.x.
HdfsEndpoint(String, CamelContext) - Constructor for class org.apache.camel.component.hdfs2.HdfsEndpoint
 
HdfsFileSystemType - Enum in org.apache.camel.component.hdfs2
 
HdfsFileType - Enum in org.apache.camel.component.hdfs2
 
HdfsFloatWritableFactory() - Constructor for class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsFloatWritableFactory
 
HdfsHeader - Enum in org.apache.camel.component.hdfs2
 
HdfsInfo - Class in org.apache.camel.component.hdfs2
 
HdfsInfoFactory - Class in org.apache.camel.component.hdfs2
 
HdfsInputStream - Class in org.apache.camel.component.hdfs2
 
HdfsInputStream() - Constructor for class org.apache.camel.component.hdfs2.HdfsInputStream
 
HdfsIntWritableFactory() - Constructor for class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsIntWritableFactory
 
HdfsLongWritableFactory() - Constructor for class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsLongWritableFactory
 
HdfsNullWritableFactory() - Constructor for class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsNullWritableFactory
 
HdfsObjectWritableFactory() - Constructor for class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsObjectWritableFactory
 
HdfsOsgiHelper - Class in org.apache.camel.component.hdfs2
Class which may be used in OSGi/Blueprint environment to perform some static initialization
HdfsOsgiHelper(Map<String, String>) - Constructor for class org.apache.camel.component.hdfs2.HdfsOsgiHelper
By using this constructor it is possible to perform static initialization of FileSystem.
HdfsOutputStream - Class in org.apache.camel.component.hdfs2
 
HdfsOutputStream() - Constructor for class org.apache.camel.component.hdfs2.HdfsOutputStream
 
HdfsProducer - Class in org.apache.camel.component.hdfs2
 
HdfsProducer(HdfsEndpoint, HdfsConfiguration) - Constructor for class org.apache.camel.component.hdfs2.HdfsProducer
 
HdfsProducer.SplitStrategy - Class in org.apache.camel.component.hdfs2
 
HdfsProducer.SplitStrategyType - Enum in org.apache.camel.component.hdfs2
 
HdfsTextWritableFactory() - Constructor for class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsTextWritableFactory
 
HdfsWritableFactories - Class in org.apache.camel.component.hdfs2
 
HdfsWritableFactories() - Constructor for class org.apache.camel.component.hdfs2.HdfsWritableFactories
 
HdfsWritableFactories.HdfsBooleanWritableFactory - Class in org.apache.camel.component.hdfs2
 
HdfsWritableFactories.HdfsBytesWritableFactory - Class in org.apache.camel.component.hdfs2
 
HdfsWritableFactories.HdfsByteWritableFactory - Class in org.apache.camel.component.hdfs2
 
HdfsWritableFactories.HdfsDoubleWritableFactory - Class in org.apache.camel.component.hdfs2
 
HdfsWritableFactories.HdfsFloatWritableFactory - Class in org.apache.camel.component.hdfs2
 
HdfsWritableFactories.HdfsIntWritableFactory - Class in org.apache.camel.component.hdfs2
 
HdfsWritableFactories.HdfsLongWritableFactory - Class in org.apache.camel.component.hdfs2
 
HdfsWritableFactories.HdfsNullWritableFactory - Class in org.apache.camel.component.hdfs2
 
HdfsWritableFactories.HdfsObjectWritableFactory - Class in org.apache.camel.component.hdfs2
 
HdfsWritableFactories.HdfsTextWritableFactory - Class in org.apache.camel.component.hdfs2
 
Holder<T> - Class in org.apache.camel.component.hdfs2
 
Holder() - Constructor for class org.apache.camel.component.hdfs2.Holder
Creates a new holder with a null value.
Holder(T) - Constructor for class org.apache.camel.component.hdfs2.Holder
Create a new holder with the specified value.

I

initHdfs() - Method in class org.apache.camel.component.hdfs2.HdfsComponent
 
isAppend() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
isBusy() - Method in class org.apache.camel.component.hdfs2.HdfsOutputStream
 
isConnectOnStartup() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
isOpened() - Method in class org.apache.camel.component.hdfs2.HdfsInputStream
 
isOverwrite() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
isSingleton() - Method in class org.apache.camel.component.hdfs2.HdfsEndpoint
 
isWantAppend() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 

N

newHdfsInfo(String) - Static method in class org.apache.camel.component.hdfs2.HdfsInfoFactory
 
next(HdfsInputStream, Holder<Object>, Holder<Object>) - Method in enum org.apache.camel.component.hdfs2.HdfsFileType
 
next(Holder<Object>, Holder<Object>) - Method in class org.apache.camel.component.hdfs2.HdfsInputStream
Reads next record/chunk specific to give file type.

O

org.apache.camel.component.hdfs2 - package org.apache.camel.component.hdfs2
 
org.apache.camel.component.hdfs2.osgi - package org.apache.camel.component.hdfs2.osgi
 

P

parseURI(URI) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
poll() - Method in class org.apache.camel.component.hdfs2.HdfsConsumer
 
process(Exchange) - Method in class org.apache.camel.component.hdfs2.HdfsProducer
 

R

read(Writable, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsBooleanWritableFactory
 
read(Writable, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsBytesWritableFactory
 
read(Writable, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsByteWritableFactory
 
read(Writable, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsDoubleWritableFactory
 
read(Writable, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsFloatWritableFactory
 
read(Writable, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsIntWritableFactory
 
read(Writable, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsLongWritableFactory
 
read(Writable, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsNullWritableFactory
 
read(Writable, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsObjectWritableFactory
 
read(Writable, Holder<Integer>) - Method in class org.apache.camel.component.hdfs2.HdfsWritableFactories.HdfsTextWritableFactory
 

S

setAppend(boolean) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
Append to existing file.
setBlockSize(long) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
The size of the HDFS blocks
setBufferSize(int) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
The buffer size used by HDFS
setCheckIdleInterval(int) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
How often (time in millis) in to run the idle checker background task.
setChunkSize(int) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
When reading a normal file, this is split into chunks producing a message per chunk.
setCompressionCodec(HdfsCompressionCodec) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
The compression codec to use
setCompressionType(SequenceFile.CompressionType) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
The compression type to use (is default not in use)
setConnectOnStartup(boolean) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
Whether to connect to the HDFS file system on starting the producer/consumer.
setFileSystemType(HdfsFileSystemType) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
Set to LOCAL to not use HDFS but local java.io.File instead.
setFileType(HdfsFileType) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
The file type to use.
setHostName(String) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
HDFS host to use
setKeyType(WritableType) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
The type for the key in case of sequence or map files.
setOpenedSuffix(String) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
When a file is opened for reading/writing the file is renamed with this suffix to avoid to read it during the writing phase.
setOverwrite(boolean) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
Whether to overwrite existing files with the same name
setOwner(String) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
The file owner must match this owner for the consumer to pickup the file.
setPath(String) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
The directory path to use
setPattern(String) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
The pattern used for scanning the directory
setPort(int) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
HDFS port to use
setReadSuffix(String) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
Once the file has been read is renamed with this suffix to avoid to read it again.
setReplication(short) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
The HDFS replication factor
setSplitStrategy(String) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
In the current version of Hadoop opening a file in append mode is disabled since it's not very reliable.
setUri(URI) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
 
setValueType(WritableType) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
The type for the key in case of sequence or map files
split(HdfsOutputStream, long, HdfsProducer) - Method in enum org.apache.camel.component.hdfs2.HdfsProducer.SplitStrategyType
 
SplitStrategy(HdfsProducer.SplitStrategyType, long) - Constructor for class org.apache.camel.component.hdfs2.HdfsProducer.SplitStrategy
 
start(BundleContext) - Method in class org.apache.camel.component.hdfs2.osgi.HdfsActivator
 
stop(BundleContext) - Method in class org.apache.camel.component.hdfs2.osgi.HdfsActivator
 

V

value - Variable in class org.apache.camel.component.hdfs2.Holder
The value contained in the holder.
valueOf(String) - Static method in enum org.apache.camel.component.hdfs2.HdfsCompressionCodec
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.camel.component.hdfs2.HdfsFileSystemType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.camel.component.hdfs2.HdfsFileType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.camel.component.hdfs2.HdfsHeader
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.camel.component.hdfs2.HdfsProducer.SplitStrategyType
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.camel.component.hdfs2.WritableType
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.camel.component.hdfs2.HdfsCompressionCodec
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.camel.component.hdfs2.HdfsFileSystemType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.camel.component.hdfs2.HdfsFileType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.camel.component.hdfs2.HdfsHeader
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.camel.component.hdfs2.HdfsProducer.SplitStrategyType
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.camel.component.hdfs2.WritableType
Returns an array containing the constants of this enum type, in the order they are declared.

W

WritableType - Enum in org.apache.camel.component.hdfs2
 
A C D G H I N O P R S V W 
Skip navigation links
Camel :: HDFS2 2.23.2.fuse-750029-redhat-00001

Apache Camel