water.init

Class NodePersistentStorage

java.lang.Object

water.init.NodePersistentStorage

public class NodePersistentStorage
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NodePersistentStorage.NodePersistentStorageEntry

Constructor Summary

Constructors

Constructor and Description
NodePersistentStorage(java.lang.String npsDir)

Method Summary

Modifier and Type	Method and Description
boolean	configured()
void	delete(java.lang.String categoryName, java.lang.String keyName)
boolean	exists(java.lang.String categoryName)
boolean	exists(java.lang.String categoryName, java.lang.String keyName)
java.lang.String	get_as_string(java.lang.String categoryName, java.lang.String keyName)
long	get_length(java.lang.String categoryName, java.lang.String keyName)
java.io.InputStream	get(java.lang.String categoryName, java.lang.String keyName, java.util.concurrent.atomic.AtomicLong length)
NodePersistentStorage.NodePersistentStorageEntry[]	list(java.lang.String categoryName)
void	put(java.lang.String categoryName, java.lang.String keyName, java.io.InputStream is)
void	put(java.lang.String categoryName, java.lang.String keyName, java.lang.String value)

Methods inherited from class java.lang.Object

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

Constructor Detail

NodePersistentStorage

public NodePersistentStorage(java.lang.String npsDir)

Method Detail

configured

public boolean configured()

exists

public boolean exists(java.lang.String categoryName)

exists

public boolean exists(java.lang.String categoryName,
                      java.lang.String keyName)

put

public void put(java.lang.String categoryName,
                java.lang.String keyName,
                java.io.InputStream is)

put

public void put(java.lang.String categoryName,
                java.lang.String keyName,
                java.lang.String value)

list

public NodePersistentStorage.NodePersistentStorageEntry[] list(java.lang.String categoryName)

get_as_string

public java.lang.String get_as_string(java.lang.String categoryName,
                                      java.lang.String keyName)

get_length

public long get_length(java.lang.String categoryName,
                       java.lang.String keyName)

get

public java.io.InputStream get(java.lang.String categoryName,
                               java.lang.String keyName,
                               java.util.concurrent.atomic.AtomicLong length)

delete

public void delete(java.lang.String categoryName,
                   java.lang.String keyName)