backtype.storm.utils

Class LocalState

java.lang.Object

backtype.storm.utils.LocalState

public class LocalState
extends Object

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

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
LocalState(String backingDir)

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup(int keepVersions)
org.apache.thrift.TBase	get(String key)
void	put(String key, org.apache.thrift.TBase val)
void	put(String key, org.apache.thrift.TBase val, boolean cleanup)
void	remove(String key)
void	remove(String key, boolean cleanup)
Map<String,org.apache.thrift.TBase>	snapshot()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static org.slf4j.Logger LOG

Constructor Detail

LocalState

public LocalState(String backingDir)
           throws IOException

Throws:

IOException

Method Detail

snapshot

public Map<String,org.apache.thrift.TBase> snapshot()

get

public org.apache.thrift.TBase get(String key)

put

public void put(String key,
       org.apache.thrift.TBase val)

put

public void put(String key,
       org.apache.thrift.TBase val,
       boolean cleanup)

remove

public void remove(String key)

remove

public void remove(String key,
          boolean cleanup)

cleanup

public void cleanup(int keepVersions)
             throws IOException

Throws:

IOException