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

A

available() - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

C

cleanUp() - Method in class org.apache.streams.s3.S3PersistReader

cleanUp() - Method in class org.apache.streams.s3.S3PersistWriter

close() - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

close() - Method in class org.apache.streams.s3.S3OutputStreamWrapper

Whenever the output stream is closed we are going to kick the ByteArrayOutputStream off to Amazon S3.

countersCurrent - Variable in class org.apache.streams.s3.S3PersistReader

countersTotal - Variable in class org.apache.streams.s3.S3PersistReader

D

DELIMITER - Static variable in class org.apache.streams.s3.S3PersistReader

E

ensureEverythingIsReleased() - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

ensureEverythingIsReleased as part of close process.

equals(Object) - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

F

finalize() - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

flush() - Method in class org.apache.streams.s3.S3OutputStreamWrapper

G

getAmazonS3Client() - Method in class org.apache.streams.s3.S3PersistReader

getAmazonS3Client() - Method in class org.apache.streams.s3.S3PersistWriter

getBucketName() - Method in class org.apache.streams.s3.S3PersistReader

getDatumStatusCounter() - Method in class org.apache.streams.s3.S3PersistReader

getDatumStatusCounter() - Method in class org.apache.streams.s3.S3PersistWriter

getFiles() - Method in class org.apache.streams.s3.S3PersistReader

getId() - Method in class org.apache.streams.s3.S3PersistReader

getId() - Method in class org.apache.streams.s3.S3PersistWriter

getObjectMapper() - Method in class org.apache.streams.s3.S3PersistWriter

getObjectMetaData() - Method in class org.apache.streams.s3.S3PersistWriter

getS3ReaderConfiguration() - Method in class org.apache.streams.s3.S3PersistReader

getS3WriterConfiguration() - Method in class org.apache.streams.s3.S3PersistWriter

getWrittenFiles() - Method in class org.apache.streams.s3.S3PersistWriter

H

hashCode() - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

I

isRunning() - Method in class org.apache.streams.s3.S3PersistReader

L

lineReaderUtil - Variable in class org.apache.streams.s3.S3PersistReader

lineWriterUtil - Variable in class org.apache.streams.s3.S3PersistWriter

M

mark(int) - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

markSupported() - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

O

org.apache.streams.s3 - package org.apache.streams.s3

P

persistQueue - Variable in class org.apache.streams.s3.S3PersistReader

prepare(Object) - Method in class org.apache.streams.s3.S3PersistReader

prepare(Object) - Method in class org.apache.streams.s3.S3PersistWriter

R

read() - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

read(byte[]) - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

read(byte[], int, int) - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

readAll() - Method in class org.apache.streams.s3.S3PersistReader

readCurrent() - Method in class org.apache.streams.s3.S3PersistReader

readNew(BigInteger) - Method in class org.apache.streams.s3.S3PersistReader

readRange(DateTime, DateTime) - Method in class org.apache.streams.s3.S3PersistReader

reset() - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

resetFile() - Method in class org.apache.streams.s3.S3PersistWriter

Reset File when it's time to create a new file.

run() - Method in class org.apache.streams.s3.S3PersistReaderTask

S

S3ObjectInputStreamWrapper - Class in org.apache.streams.s3

There is a nuance associated with reading portions of files in S3.

S3ObjectInputStreamWrapper(S3Object) - Constructor for class org.apache.streams.s3.S3ObjectInputStreamWrapper

Create an input stream safely.

S3OutputStreamWrapper - Class in org.apache.streams.s3

This class uses ByteArrayOutputStreams to ensure files are written to S3 properly.

S3OutputStreamWrapper(AmazonS3Client, String, String, String, Map<String, String>) - Constructor for class org.apache.streams.s3.S3OutputStreamWrapper

Create an OutputStream Wrapper

S3PersistReader - Class in org.apache.streams.s3

S3PersistReader reads documents from s3.

S3PersistReader(S3ReaderConfiguration) - Constructor for class org.apache.streams.s3.S3PersistReader

S3PersistReaderTask - Class in org.apache.streams.s3

S3PersistReaderTask reads documents from s3 on behalf of

S3PersistReaderTask(S3PersistReader) - Constructor for class org.apache.streams.s3.S3PersistReaderTask

S3PersistWriter - Class in org.apache.streams.s3

S3PersistWriter writes documents to s3.

S3PersistWriter() - Constructor for class org.apache.streams.s3.S3PersistWriter

S3PersistWriter(S3WriterConfiguration) - Constructor for class org.apache.streams.s3.S3PersistWriter

S3PersistWriter(AmazonS3Client, S3WriterConfiguration) - Constructor for class org.apache.streams.s3.S3PersistWriter

Instantiator with a pre-existing amazonS3Client, this is used to help with re-use.

setObjectMapper(ObjectMapper) - Method in class org.apache.streams.s3.S3PersistWriter

setObjectMetaData(Map<String, String>) - Method in class org.apache.streams.s3.S3PersistWriter

skip(long) - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

startStream() - Method in class org.apache.streams.s3.S3PersistReader

STREAMS_ID - Static variable in class org.apache.streams.s3.S3PersistReader

STREAMS_ID - Static variable in class org.apache.streams.s3.S3PersistWriter

T

toString() - Method in class org.apache.streams.s3.S3ObjectInputStreamWrapper

W

write(int) - Method in class org.apache.streams.s3.S3OutputStreamWrapper

write(byte[]) - Method in class org.apache.streams.s3.S3OutputStreamWrapper

write(byte[], int, int) - Method in class org.apache.streams.s3.S3OutputStreamWrapper

write(StreamsDatum) - Method in class org.apache.streams.s3.S3PersistWriter

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