org.apache.streams.s3

Class S3OutputStreamWrapper

java.lang.Object

java.io.OutputStream

org.apache.streams.s3.S3OutputStreamWrapper

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable

public class S3OutputStreamWrapper
extends OutputStream

This class uses ByteArrayOutputStreams to ensure files are written to S3 properly. The stream is written to the in memory ByteArrayOutPutStream before it is finally written to Amazon S3. The size the file is allowed to become is directly controlled by the S3PersistWriter.

Constructor Summary

Constructors

Constructor and Description
S3OutputStreamWrapper(com.amazonaws.services.s3.AmazonS3Client amazonS3Client, String bucketName, String path, String fileName, Map<String,String> metaData) Create an OutputStream Wrapper

Method Summary

Modifier and Type	Method and Description
void	close() Whenever the output stream is closed we are going to kick the ByteArrayOutputStream off to Amazon S3.
void	flush()
void	write(byte[] byt)
void	write(byte[] byt, int off, int len)
void	write(int byt)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

S3OutputStreamWrapper

public S3OutputStreamWrapper(com.amazonaws.services.s3.AmazonS3Client amazonS3Client,
                             String bucketName,
                             String path,
                             String fileName,
                             Map<String,String> metaData)
                      throws IOException

Create an OutputStream Wrapper

Parameters:

amazonS3Client - The Amazon S3 Client which will be handling the file

bucketName - The Bucket Name you are wishing to write to.

path - The path where the object will live

fileName - The fileName you ware wishing to write.

metaData - Any meta data that is to be written along with the object

Throws:

IOException - If there is an issue creating the stream, this

Method Detail

write

public void write(int byt)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] byt)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] byt,
                  int off,
                  int len)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Overrides:

flush in class OutputStream

Throws:

IOException

close

public void close()
           throws IOException

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

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class OutputStream

Throws:

IOException - Exception thrown from the FileOutputStream