alluxio.worker.dora

Class RocksDBDoraMetaStore

java.lang.Object

alluxio.worker.dora.RocksDBDoraMetaStore

All Implemented Interfaces:

DoraMetaStore

@ThreadSafe
public class RocksDBDoraMetaStore
extends Object
implements DoraMetaStore

Dora Meta Store in RocksDB.

Constructor Summary

Constructors

Constructor and Description
RocksDBDoraMetaStore(String baseDir, long metaTTL) Creates and initializes a rocks block store.

Method Summary

Modifier and Type	Method and Description
void	clear() Clears all the metadata in this RocksDB.
void	close() Closes the RocksDb and all resources.
Optional<DoraMeta.FileStatus>	getDoraMeta(String path) Queries the metadata for a file.
void	putDoraMeta(String path, DoraMeta.FileStatus meta) Stores the metadata identified by URI of the file into this RocksDB.
void	removeDoraMeta(String path) Removes the metadata from the RocksDB.
Optional<Long>	size() Queries the estimated number of the records in this RocksDB.

Methods inherited from class java.lang.Object

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

Constructor Detail

RocksDBDoraMetaStore

public RocksDBDoraMetaStore(String baseDir,
                            long metaTTL)

Creates and initializes a rocks block store.

Parameters:

baseDir - the base directory in which to store inode metadata

metaTTL - The TTL for this metastore

Method Detail

getDoraMeta

public Optional<DoraMeta.FileStatus> getDoraMeta(String path)

Queries the metadata for a file.

Specified by:

getDoraMeta in interface DoraMetaStore

Parameters:

path - the full path of this file

Returns:

the metadata if found, Optional.empty if not found

putDoraMeta

public void putDoraMeta(String path,
                        DoraMeta.FileStatus meta)

Stores the metadata identified by URI of the file into this RocksDB.

Specified by:

putDoraMeta in interface DoraMetaStore

Parameters:

path - the full path of this file

meta - the block metadata

removeDoraMeta

public void removeDoraMeta(String path)

Removes the metadata from the RocksDB. It is not an error if the record specified by the key is not found.

Specified by:

removeDoraMeta in interface DoraMetaStore

Parameters:

path - the full path of the file whose metadata to be removed

clear

public void clear()

Clears all the metadata in this RocksDB.

Specified by:

clear in interface DoraMetaStore

close

public void close()

Closes the RocksDb and all resources.

Specified by:

close in interface DoraMetaStore

size

public Optional<Long> size()

Queries the estimated number of the records in this RocksDB. Please note, this is not an accurate number.

Specified by:

size in interface DoraMetaStore

Returns:

the estimated number of records