Package cz.o2.proxima.direct.io.s3

Class S3FileSystem

java.lang.Object

cz.o2.proxima.direct.io.s3.S3FileSystem

All Implemented Interfaces:

FileSystem, java.io.Serializable

@Internal
public class S3FileSystem
extends java.lang.Object
implements FileSystem

FileSystem implementation for gs://.

See Also:

Serialized Form

Method Summary

Modifier and Type	Method	Description
void	deleteObject(java.lang.String key)
com.amazonaws.services.s3.model.S3Object	getObject(java.lang.String blobName)
java.net.URI	getUri()	Ger URI representation of this FileSystem
java.util.stream.Stream<Path>	list(long minTs, long maxTs)	Return stream of Paths that represent given time range.
Path	newPath(long ts)	Create new Path.
java.io.OutputStream	putObject(java.lang.String blobName)	Put object to s3 using multi-part upload.

Methods inherited from class java.lang.Object

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

Methods inherited from interface cz.o2.proxima.direct.io.bulkfs.FileSystem

list

Method Detail

getUri

public java.net.URI getUri()

Description copied from interface: FileSystem

Ger URI representation of this FileSystem

Specified by:

getUri in interface FileSystem

Returns:

the URI of this FileSystem

list

public java.util.stream.Stream<Path> list(long minTs,
                                          long maxTs)

Description copied from interface: FileSystem

Return stream of Paths that represent given time range.

Specified by:

list in interface FileSystem

Parameters:

minTs - minimal allowed timestamp (inclusive)

maxTs - maximal allowd timestamp (exclusive)

Returns:

stream of Paths satisfying given time range

newPath

public Path newPath(long ts)

Description copied from interface: FileSystem

Create new Path.

Specified by:

newPath in interface FileSystem

Parameters:

ts - timestamp to create the path for

Returns:

new abstract Path object

getObject

public com.amazonaws.services.s3.model.S3Object getObject(java.lang.String blobName)

deleteObject

public void deleteObject(java.lang.String key)

putObject

public java.io.OutputStream putObject(java.lang.String blobName)

Put object to s3 using multi-part upload.

Parameters:

blobName - Name of the blob we want to write.

Returns:

Output stream that we can write data into.