Index (Camel :: HDFS2 2.18.1.redhat-000025 API)

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
getDelay() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
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
getInitialDelay() - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration
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.
setDelay(long) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration: The interval (milliseconds) between the directory scans.
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
setInitialDelay(long) - Method in class org.apache.camel.component.hdfs2.HdfsConfiguration: For the consumer, how much to wait (milliseconds) before to start scanning the directory.
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