edu.iu.dsc.tws.checkpointing.stores

Class LocalFileStateStore

java.lang.Object

edu.iu.dsc.tws.checkpointing.stores.LocalFileStateStore

All Implemented Interfaces:

StateStore

public class LocalFileStateStore
extends java.lang.Object
implements StateStore

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CHECKPOINTING_STORE_FS_DIR

Constructor Summary

Constructors

Constructor and Description
LocalFileStateStore()

Method Summary

Modifier and Type	Method and Description
boolean	contains(java.lang.String key) Check weather the specified key is in the store
byte[]	get(java.lang.String key) Get the bye value of the key
void	init(Config config, java.lang.String... path) Initialize the store
void	put(java.lang.String key, byte[] data) Put a key and data

Methods inherited from class java.lang.Object

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

Field Detail

CHECKPOINTING_STORE_FS_DIR

public static final java.lang.String CHECKPOINTING_STORE_FS_DIR

See Also:

Constant Field Values

Constructor Detail

LocalFileStateStore

public LocalFileStateStore()

Method Detail

init

public void init(Config config,
                 java.lang.String... path)

Description copied from interface: StateStore

Initialize the store

Specified by:

init in interface StateStore

Parameters:

config - configuration

path - path

put

public void put(java.lang.String key,
                byte[] data)
         throws java.io.IOException

Description copied from interface: StateStore

Put a key and data

Specified by:

put in interface StateStore

Parameters:

key - key

data - data

Throws:

java.io.IOException - if an error occurs

get

public byte[] get(java.lang.String key)
           throws java.io.IOException

Description copied from interface: StateStore

Get the bye value of the key

Specified by:

get in interface StateStore

Parameters:

key - key

Returns:

byte array

Throws:

java.io.IOException - if an error occurs

contains

public boolean contains(java.lang.String key)
                 throws java.io.IOException

Description copied from interface: StateStore

Check weather the specified key is in the store

Specified by:

contains in interface StateStore

Parameters:

key - key

Returns:

true if the key in store

Throws:

java.io.IOException - if an error occurs