A C D E F G H I L M O P R S T V 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.S3Configuration

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

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

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

F

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

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

fromValue(String) - Static method in enum org.apache.streams.s3.S3Configuration.Protocol

fromValue(String) - Static method in enum org.apache.streams.s3.S3WriterConfiguration.Compression

G

getAdditionalProperties() - Method in class org.apache.streams.s3.S3Configuration

getAdditionalProperties() - Method in class org.apache.streams.s3.S3ReaderConfiguration

getAdditionalProperties() - Method in class org.apache.streams.s3.S3WriterConfiguration

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

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

getBucket() - Method in class org.apache.streams.s3.S3Configuration

Your AWS bucket (Required)

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

getChunk() - Method in class org.apache.streams.s3.S3WriterConfiguration

Whether you want the file chunked inside of a folder or not

getCompression() - Method in class org.apache.streams.s3.S3WriterConfiguration

compression

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

getKey() - Method in class org.apache.streams.s3.S3Configuration

Your Amazon Key (Required)

getMaxFileSize() - Method in class org.apache.streams.s3.S3WriterConfiguration

If files are elected to be 'chunked' which they are by default, this is the maximum size of that file before the byte array stream is vacated and the file is created.

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

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

getProtocol() - Method in class org.apache.streams.s3.S3Configuration

Whether you are using HTTP or HTTPS

getReaderPath() - Method in class org.apache.streams.s3.S3ReaderConfiguration

Path below root path

getRegion() - Method in class org.apache.streams.s3.S3Configuration

The AWS region where your bucket resides

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

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

getSecretKey() - Method in class org.apache.streams.s3.S3Configuration

Your Amazon Secret Key (Required)

getWriterFilePrefix() - Method in class org.apache.streams.s3.S3WriterConfiguration

File Prefix

getWriterPath() - Method in class org.apache.streams.s3.S3WriterConfiguration

Path

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

H

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

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

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

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

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

S3Configuration - Class in org.apache.streams.s3

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

S3Configuration.Protocol - Enum in org.apache.streams.s3

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.

S3ReaderConfiguration - Class in org.apache.streams.s3

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

S3WriterConfiguration - Class in org.apache.streams.s3

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

S3WriterConfiguration.Compression - Enum in org.apache.streams.s3

setAdditionalProperty(String, Object) - Method in class org.apache.streams.s3.S3Configuration

setAdditionalProperty(String, Object) - Method in class org.apache.streams.s3.S3ReaderConfiguration

setAdditionalProperty(String, Object) - Method in class org.apache.streams.s3.S3WriterConfiguration

setBucket(String) - Method in class org.apache.streams.s3.S3Configuration

Your AWS bucket (Required)

setChunk(Boolean) - Method in class org.apache.streams.s3.S3WriterConfiguration

Whether you want the file chunked inside of a folder or not

setCompression(S3WriterConfiguration.Compression) - Method in class org.apache.streams.s3.S3WriterConfiguration

compression

setKey(String) - Method in class org.apache.streams.s3.S3Configuration

Your Amazon Key (Required)

setMaxFileSize(Long) - Method in class org.apache.streams.s3.S3WriterConfiguration

If files are elected to be 'chunked' which they are by default, this is the maximum size of that file before the byte array stream is vacated and the file is created.

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

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

setProtocol(S3Configuration.Protocol) - Method in class org.apache.streams.s3.S3Configuration

Whether you are using HTTP or HTTPS

setReaderPath(String) - Method in class org.apache.streams.s3.S3ReaderConfiguration

Path below root path

setRegion(String) - Method in class org.apache.streams.s3.S3Configuration

The AWS region where your bucket resides

setSecretKey(String) - Method in class org.apache.streams.s3.S3Configuration

Your Amazon Secret Key (Required)

setWriterFilePrefix(String) - Method in class org.apache.streams.s3.S3WriterConfiguration

File Prefix

setWriterPath(String) - Method in class org.apache.streams.s3.S3WriterConfiguration

Path

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 enum org.apache.streams.s3.S3Configuration.Protocol

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

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

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

toString() - Method in enum org.apache.streams.s3.S3WriterConfiguration.Compression

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

V

valueOf(String) - Static method in enum org.apache.streams.s3.S3Configuration.Protocol

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

valueOf(String) - Static method in enum org.apache.streams.s3.S3WriterConfiguration.Compression

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

values() - Static method in enum org.apache.streams.s3.S3Configuration.Protocol

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

values() - Static method in enum org.apache.streams.s3.S3WriterConfiguration.Compression

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

W

withAdditionalProperty(String, Object) - Method in class org.apache.streams.s3.S3Configuration

withAdditionalProperty(String, Object) - Method in class org.apache.streams.s3.S3ReaderConfiguration

withAdditionalProperty(String, Object) - Method in class org.apache.streams.s3.S3WriterConfiguration

withBucket(String) - Method in class org.apache.streams.s3.S3Configuration

withChunk(Boolean) - Method in class org.apache.streams.s3.S3WriterConfiguration

withCompression(S3WriterConfiguration.Compression) - Method in class org.apache.streams.s3.S3WriterConfiguration

withKey(String) - Method in class org.apache.streams.s3.S3Configuration

withMaxFileSize(Long) - Method in class org.apache.streams.s3.S3WriterConfiguration

withProtocol(S3Configuration.Protocol) - Method in class org.apache.streams.s3.S3Configuration

withReaderPath(String) - Method in class org.apache.streams.s3.S3ReaderConfiguration

withRegion(String) - Method in class org.apache.streams.s3.S3Configuration

withSecretKey(String) - Method in class org.apache.streams.s3.S3Configuration

withWriterFilePrefix(String) - Method in class org.apache.streams.s3.S3WriterConfiguration

withWriterPath(String) - Method in class org.apache.streams.s3.S3WriterConfiguration

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 V W