org.apache.samza.metadatastore

Class InMemoryMetadataStore

java.lang.Object

org.apache.samza.metadatastore.InMemoryMetadataStore

All Implemented Interfaces:

MetadataStore

public class InMemoryMetadataStore
extends java.lang.Object
implements MetadataStore

In-memory MetadataStore with no persistence on disk.

Constructor Summary

Constructors

Constructor and Description
InMemoryMetadataStore()

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,byte[]>	all() Returns all the entries in this metadata store.
void	close() Closes the metadata store, if applicable, relinquishing all the underlying resources and connections.
void	delete(java.lang.String key) Deletes the mapping for the specified key from this metadata store (if such mapping exists).
void	flush() Flushes the metadata store, if applicable.
byte[]	get(java.lang.String key) Gets the value associated with the specified key.
void	init() Initializes the metadata store, if applicable, setting up the underlying resources and connections to the store endpoints.
void	put(java.lang.String key, byte[] value) Updates the mapping of the specified key-value pair.

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryMetadataStore

public InMemoryMetadataStore()

Method Detail

init

public void init()

Description copied from interface: MetadataStore

Initializes the metadata store, if applicable, setting up the underlying resources and connections to the store endpoints.

Specified by:

init in interface MetadataStore

get

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

Description copied from interface: MetadataStore

Gets the value associated with the specified key.

Specified by:

get in interface MetadataStore

Parameters:

key - the key with which the associated value is to be fetched.

Returns:

if found, the value associated with the specified key; otherwise, null.

put

public void put(java.lang.String key,
                byte[] value)

Description copied from interface: MetadataStore

Updates the mapping of the specified key-value pair.

Specified by:

put in interface MetadataStore

Parameters:

key - the key with which the specified value is to be associated.

value - the value with which the specified key is to be associated.

delete

public void delete(java.lang.String key)

Description copied from interface: MetadataStore

Deletes the mapping for the specified key from this metadata store (if such mapping exists).

Specified by:

delete in interface MetadataStore

Parameters:

key - the key for which the mapping is to be deleted.

all

public java.util.Map<java.lang.String,byte[]> all()

Description copied from interface: MetadataStore

Returns all the entries in this metadata store.

Specified by:

all in interface MetadataStore

Returns:

all entries in this metadata store.

flush

public void flush()

Description copied from interface: MetadataStore

Flushes the metadata store, if applicable.

Specified by:

flush in interface MetadataStore

close

public void close()

Description copied from interface: MetadataStore

Closes the metadata store, if applicable, relinquishing all the underlying resources and connections.

Specified by:

close in interface MetadataStore