C D E F G H I L M O P R S T V W

C

cleanUp() - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

cleanUp() - Method in class org.apache.streams.hdfs.WebHdfsPersistWriter

client - Variable in class org.apache.streams.hdfs.WebHdfsPersistReader

close() - Method in class org.apache.streams.hdfs.WebHdfsPersistWriter

countersCurrent - Variable in class org.apache.streams.hdfs.WebHdfsPersistReader

countersTotal - Variable in class org.apache.streams.hdfs.WebHdfsPersistReader

D

DELIMITER - Static variable in class org.apache.streams.hdfs.WebHdfsPersistReader

DOC - Static variable in class org.apache.streams.hdfs.HdfsConstants

E

equals(Object) - Method in class org.apache.streams.hdfs.HdfsConfiguration

equals(Object) - Method in class org.apache.streams.hdfs.HdfsReaderConfiguration

equals(Object) - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

F

flush() - Method in class org.apache.streams.hdfs.WebHdfsPersistWriter

fromValue(String) - Static method in enum org.apache.streams.hdfs.HdfsConfiguration.Scheme

fromValue(String) - Static method in enum org.apache.streams.hdfs.HdfsWriterConfiguration.Compression

G

getAdditionalProperties() - Method in class org.apache.streams.hdfs.HdfsConfiguration

getAdditionalProperties() - Method in class org.apache.streams.hdfs.HdfsReaderConfiguration

getAdditionalProperties() - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

getCompression() - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

compression

getDatumStatusCounter() - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

getDatumStatusCounter() - Method in class org.apache.streams.hdfs.WebHdfsPersistWriter

getFileSystem() - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

getFileSystem.

getFileSystem() - Method in class org.apache.streams.hdfs.WebHdfsPersistWriter

getFileSystem.

getHost() - Method in class org.apache.streams.hdfs.HdfsConfiguration

WebHdfs host

getId() - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

getId() - Method in class org.apache.streams.hdfs.WebHdfsPersistWriter

getLinesPerFile() - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

Lines Per File

getPassword() - Method in class org.apache.streams.hdfs.HdfsConfiguration

Password

getPath() - Method in class org.apache.streams.hdfs.HdfsConfiguration

Base path

getPort() - Method in class org.apache.streams.hdfs.HdfsConfiguration

WebHdfs port

getReaderPath() - Method in class org.apache.streams.hdfs.HdfsReaderConfiguration

Path below root path

getScheme() - Method in class org.apache.streams.hdfs.HdfsConfiguration

scheme

getURI() - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

getURI from hdfsConfiguration.

getURI() - Method in class org.apache.streams.hdfs.WebHdfsPersistWriter

getURI from hdfsConfiguration.

getUser() - Method in class org.apache.streams.hdfs.HdfsConfiguration

User

getWriterFilePrefix() - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

File Prefix

getWriterPath() - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

Path

H

hashCode() - Method in class org.apache.streams.hdfs.HdfsConfiguration

hashCode() - Method in class org.apache.streams.hdfs.HdfsReaderConfiguration

hashCode() - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

HdfsConfiguration - Class in org.apache.streams.hdfs

HdfsConfiguration() - Constructor for class org.apache.streams.hdfs.HdfsConfiguration

hdfsConfiguration - Variable in class org.apache.streams.hdfs.WebHdfsPersistReader

hdfsConfiguration - Variable in class org.apache.streams.hdfs.WebHdfsPersistWriter

HdfsConfiguration.Scheme - Enum in org.apache.streams.hdfs

HdfsConstants - Class in org.apache.streams.hdfs

Predefined field symbols for streams-persist-hdfs.

HdfsConstants() - Constructor for class org.apache.streams.hdfs.HdfsConstants

HdfsReaderConfiguration - Class in org.apache.streams.hdfs

HdfsReaderConfiguration() - Constructor for class org.apache.streams.hdfs.HdfsReaderConfiguration

HdfsWriterConfiguration - Class in org.apache.streams.hdfs

HdfsWriterConfiguration() - Constructor for class org.apache.streams.hdfs.HdfsWriterConfiguration

HdfsWriterConfiguration.Compression - Enum in org.apache.streams.hdfs

I

ID - Static variable in class org.apache.streams.hdfs.HdfsConstants

isConnected() - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

isConnected.

isConnected() - Method in class org.apache.streams.hdfs.WebHdfsPersistWriter

isConnected.

isRunning() - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

L

lineReaderUtil - Variable in class org.apache.streams.hdfs.WebHdfsPersistReader

M

mapper - Variable in class org.apache.streams.hdfs.WebHdfsPersistReader

META - Static variable in class org.apache.streams.hdfs.HdfsConstants

O

org.apache.streams.hdfs - package org.apache.streams.hdfs

P

path - Variable in class org.apache.streams.hdfs.WebHdfsPersistReader

persistQueue - Variable in class org.apache.streams.hdfs.WebHdfsPersistReader

persistQueue - Variable in class org.apache.streams.hdfs.WebHdfsPersistWriter

prepare(Object) - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

prepare(Object) - Method in class org.apache.streams.hdfs.WebHdfsPersistWriter

R

readAll() - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

readCurrent() - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

readNew(BigInteger) - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

readRange(DateTime, DateTime) - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

run() - Method in class org.apache.streams.hdfs.WebHdfsPersistReaderTask

run() - Method in class org.apache.streams.hdfs.WebHdfsPersistWriterTask

S

setAdditionalProperty(String, Object) - Method in class org.apache.streams.hdfs.HdfsConfiguration

setAdditionalProperty(String, Object) - Method in class org.apache.streams.hdfs.HdfsReaderConfiguration

setAdditionalProperty(String, Object) - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

setCompression(HdfsWriterConfiguration.Compression) - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

compression

setHost(String) - Method in class org.apache.streams.hdfs.HdfsConfiguration

WebHdfs host

setLinesPerFile(Long) - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

Lines Per File

setPassword(String) - Method in class org.apache.streams.hdfs.HdfsConfiguration

Password

setPath(String) - Method in class org.apache.streams.hdfs.HdfsConfiguration

Base path

setPort(Long) - Method in class org.apache.streams.hdfs.HdfsConfiguration

WebHdfs port

setReaderPath(String) - Method in class org.apache.streams.hdfs.HdfsReaderConfiguration

Path below root path

setScheme(HdfsConfiguration.Scheme) - Method in class org.apache.streams.hdfs.HdfsConfiguration

scheme

setUser(String) - Method in class org.apache.streams.hdfs.HdfsConfiguration

User

setWriterFilePrefix(String) - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

File Prefix

setWriterPath(String) - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

Path

startStream() - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

status - Variable in class org.apache.streams.hdfs.WebHdfsPersistReader

STREAMS_ID - Static variable in class org.apache.streams.hdfs.WebHdfsPersistReader

STREAMS_ID - Static variable in class org.apache.streams.hdfs.WebHdfsPersistWriter

streamsConfiguration - Variable in class org.apache.streams.hdfs.WebHdfsPersistReader

T

terminate - Variable in class org.apache.streams.hdfs.WebHdfsPersistWriter

toString() - Method in enum org.apache.streams.hdfs.HdfsConfiguration.Scheme

toString() - Method in class org.apache.streams.hdfs.HdfsConfiguration

toString() - Method in class org.apache.streams.hdfs.HdfsReaderConfiguration

toString() - Method in enum org.apache.streams.hdfs.HdfsWriterConfiguration.Compression

toString() - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

TS - Static variable in class org.apache.streams.hdfs.HdfsConstants

V

valueOf(String) - Static method in enum org.apache.streams.hdfs.HdfsConfiguration.Scheme

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.streams.hdfs.HdfsWriterConfiguration.Compression

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.streams.hdfs.HdfsConfiguration.Scheme

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.streams.hdfs.HdfsWriterConfiguration.Compression

Returns an array containing the constants of this enum type, in the order they are declared.

W

WebHdfsPersistReader - Class in org.apache.streams.hdfs

WebHdfsPersistReader reads from hdfs.

WebHdfsPersistReader() - Constructor for class org.apache.streams.hdfs.WebHdfsPersistReader

WebHdfsPersistReader constructor - resolves HdfsReaderConfiguration from JVM 'hdfs'.

WebHdfsPersistReader(HdfsReaderConfiguration) - Constructor for class org.apache.streams.hdfs.WebHdfsPersistReader

WebHdfsPersistReader constructor - uses supplied HdfsReaderConfiguration.

WebHdfsPersistReaderTask - Class in org.apache.streams.hdfs

WebHdfsPersistReaderTask reads from hdfs on behalf of

WebHdfsPersistReaderTask(WebHdfsPersistReader) - Constructor for class org.apache.streams.hdfs.WebHdfsPersistReaderTask

WebHdfsPersistWriter - Class in org.apache.streams.hdfs

WebHdfsPersistWriter writes to hdfs.

WebHdfsPersistWriter() - Constructor for class org.apache.streams.hdfs.WebHdfsPersistWriter

WebHdfsPersistWriter(HdfsWriterConfiguration) - Constructor for class org.apache.streams.hdfs.WebHdfsPersistWriter

WebHdfsPersistWriterTask - Class in org.apache.streams.hdfs

WebHdfsPersistReaderTask writes to hdfs on behalf of

WebHdfsPersistWriterTask(WebHdfsPersistWriter) - Constructor for class org.apache.streams.hdfs.WebHdfsPersistWriterTask

withAdditionalProperty(String, Object) - Method in class org.apache.streams.hdfs.HdfsConfiguration

withAdditionalProperty(String, Object) - Method in class org.apache.streams.hdfs.HdfsReaderConfiguration

withAdditionalProperty(String, Object) - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

withCompression(HdfsWriterConfiguration.Compression) - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

withHost(String) - Method in class org.apache.streams.hdfs.HdfsConfiguration

withLinesPerFile(Long) - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

withPassword(String) - Method in class org.apache.streams.hdfs.HdfsConfiguration

withPath(String) - Method in class org.apache.streams.hdfs.HdfsConfiguration

withPort(Long) - Method in class org.apache.streams.hdfs.HdfsConfiguration

withReaderPath(String) - Method in class org.apache.streams.hdfs.HdfsReaderConfiguration

withScheme(HdfsConfiguration.Scheme) - Method in class org.apache.streams.hdfs.HdfsConfiguration

withUser(String) - Method in class org.apache.streams.hdfs.HdfsConfiguration

withWriterFilePrefix(String) - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

withWriterPath(String) - Method in class org.apache.streams.hdfs.HdfsWriterConfiguration

write(StreamsDatum) - Method in class org.apache.streams.hdfs.WebHdfsPersistReader

write(StreamsDatum) - Method in class org.apache.streams.hdfs.WebHdfsPersistWriter

C D E F G H I L M O P R S T V W