edu.iu.dsc.tws.checkpointing.stores

Class HDFSFileStateStore

java.lang.Object

edu.iu.dsc.tws.checkpointing.stores.HDFSFileStateStore

All Implemented Interfaces:

StateStore

public class HDFSFileStateStore
extends java.lang.Object
implements StateStore

Constructor Summary

Constructors

Constructor and Description
HDFSFileStateStore()

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

Constructor Detail

HDFSFileStateStore

public HDFSFileStateStore()

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