public final class PersistS3 extends Persist
Persist.PersistEntry
Constructor and Description |
---|
PersistS3() |
Modifier and Type | Method and Description |
---|---|
java.util.ArrayList<java.lang.String> |
calcTypeaheadMatches(java.lang.String src,
int limit)
Calculate typeahead matches for src
|
void |
cleanUp()
Delete persistent storage on startup and shutdown
|
void |
delete(Value v)
Reclaim space from a previously stored Value
|
static water.persist.PersistS3.AmazonS3 |
getClient()
Initialize the AWS S3 client
|
void |
importFiles(java.lang.String path,
java.util.ArrayList<java.lang.String> files,
java.util.ArrayList<java.lang.String> keys,
java.util.ArrayList<java.lang.String> fails,
java.util.ArrayList<java.lang.String> dels) |
byte[] |
load(Value v)
Load a previously stored Value
|
static java.io.InputStream |
openStream(Key k,
Job pmon)
InputStream from a S3-based Key
|
void |
store(Value v)
Store a Value into persistent storage, consuming some storage space.
|
Key |
uriToKey(java.net.URI uri)
Transform given uri into file vector holding file name.
|
create, delete, exists, getHomeDirectory, getTotalSpace, getUsableSpace, length, list, mkdirs, open, rename
public static water.persist.PersistS3.AmazonS3 getClient()
public void cleanUp()
Persist
public static java.io.InputStream openStream(Key k, Job pmon) throws java.io.IOException
java.io.IOException
public byte[] load(Value v)
Persist
public void store(Value v)
Persist
public void delete(Value v)
Persist
public Key uriToKey(java.net.URI uri) throws java.io.IOException
Persist
public java.util.ArrayList<java.lang.String> calcTypeaheadMatches(java.lang.String src, int limit)
Persist
calcTypeaheadMatches
in class Persist
src
- Source string to match for typeaheadlimit
- Max number of entries to returnpublic void importFiles(java.lang.String path, java.util.ArrayList<java.lang.String> files, java.util.ArrayList<java.lang.String> keys, java.util.ArrayList<java.lang.String> fails, java.util.ArrayList<java.lang.String> dels)
importFiles
in class Persist