water.persist

Class PersistS3

java.lang.Object

water.persist.Persist

water.persist.PersistS3

public final class PersistS3
extends Persist

Persistence backend for S3

Nested Class Summary

Nested classes/interfaces inherited from class water.persist.Persist

Persist.Schemes

Field Summary

Fields inherited from class water.persist.Persist

I, UNKNOWN

Constructor Summary

Constructors

Constructor and Description
PersistS3()

Method Summary

Methods

Modifier and Type	Method and Description
void	clear()
void	delete(Value v)
static water.persist.PersistS3.AmazonS3	getClient()
java.lang.String	getPath()
byte[]	load(Value v) Value should already be persisted to disk.
static java.io.InputStream	openStream(Key k, Job pmon)
void	store(Value v)

Methods inherited from class water.persist.Persist

get, getIce, getTotalSpace, getUsableSpace, initialize, toByteArray

Methods inherited from class java.lang.Object

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

Constructor Detail

PersistS3

public PersistS3()

Method Detail

getClient

public static water.persist.PersistS3.AmazonS3 getClient()

openStream

public static java.io.InputStream openStream(Key k,
                             Job pmon)
                                      throws java.io.IOException

Throws:

java.io.IOException

load

public byte[] load(Value v)

Description copied from class: Persist

Value should already be persisted to disk. A racing delete can trigger a failure where we get a null return, but no crash (although one could argue that a racing load and delete is a bug no matter what).

Specified by:

load in class Persist

store

public void store(Value v)

Specified by:

store in class Persist

getPath

public java.lang.String getPath()

Specified by:

getPath in class Persist

clear

public void clear()

Specified by:

clear in class Persist

delete

public void delete(Value v)

Specified by:

delete in class Persist