backtype.storm.utils
Class LocalState

java.lang.Object
  backtype.storm.utils.LocalState

public class LocalState
extends java.lang.Object

A simple, durable, atomic K/V database. *Very inefficient*, should only be used for occasional reads/writes. Every read/write hits disk.

Constructor Summary

LocalState(java.lang.String backingDir)

Method Summary

java.lang.Object	get(java.lang.Object key)
void	put(java.lang.Object key, java.lang.Object val)
void	remove(java.lang.Object key)
java.util.Map<java.lang.Object,java.lang.Object>	snapshot()

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalState

public LocalState(java.lang.String backingDir)
           throws java.io.IOException

Throws:

java.io.IOException

Method Detail

snapshot

public java.util.Map<java.lang.Object,java.lang.Object> snapshot()
                                                          throws java.io.IOException

Throws:

java.io.IOException

get

public java.lang.Object get(java.lang.Object key)
                     throws java.io.IOException

Throws:

java.io.IOException

put

public void put(java.lang.Object key,
                java.lang.Object val)
         throws java.io.IOException

Throws:

java.io.IOException

remove

public void remove(java.lang.Object key)
            throws java.io.IOException

Throws:

java.io.IOException