alluxio.master.table

Class Database

java.lang.Object

alluxio.master.table.Database

All Implemented Interfaces:

Checkpointed, Journaled, JournalEntryIterable

public class Database
extends Object
implements Journaled

The database implementation that manages a collection of tables.

Method Summary

Modifier and Type	Method and Description
void	applyAndJournal(java.util.function.Supplier<JournalContext> context, Journal.JournalEntry entry) Applies and journals a journal entry.
static Database	create(CatalogContext catalogContext, UdbContext udbContext, String type, String name, Map<String,String> configMap) Creates an instance of a database.
Table	createTable(String tableName, Schema schema) Creates a new table within this database.
CheckpointName	getCheckpointName()
Map<String,String>	getConfig()
CatalogContext	getContext()
DatabaseInfo	getDatabaseInfo()
CloseableIterator<Journal.JournalEntry>	getJournalEntryIterator()
String	getName()
Map<String,FileStatistics>	getStatistics(String tableName)
Table	getTable(String tableName)
List<Table>	getTables()
String	getType()
UnderDatabase	getUdb()
boolean	processJournalEntry(Journal.JournalEntry entry) Attempts to apply a journal entry.
void	resetState() Resets the object's journaled state.
SyncStatus	sync(JournalContext context) Syncs the metadata from the under db.
static Table.UpdateDatabaseInfoEntry	toJournalProto(DatabaseInfo dbInfo, String dbName)

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.master.journal.Journaled

restoreFromCheckpoint, writeToCheckpoint

Method Detail

create

public static Database create(CatalogContext catalogContext,
                              UdbContext udbContext,
                              String type,
                              String name,
                              Map<String,String> configMap)

Creates an instance of a database.

Parameters:

catalogContext - the catalog context

udbContext - the db context

type - the database type

name - the database name

configMap - the configuration

Returns:

the database instance

getContext

public CatalogContext getContext()

Returns:

the catalog context

getName

public String getName()

Returns:

returns the database name

getDatabaseInfo

public DatabaseInfo getDatabaseInfo()

Returns:

returns database info

getType

public String getType()

Returns:

returns the database type

getUdb

public UnderDatabase getUdb()

Returns:

the UnderDatabase

getTables

public List<Table> getTables()

Returns:

the list of all tables

getTable

public Table getTable(String tableName)
               throws NotFoundException

Parameters:

tableName - the table name

Returns:

the Table for the specified table name

Throws:

NotFoundException

createTable

public Table createTable(String tableName,
                         Schema schema)

Creates a new table within this database.

Parameters:

tableName - the new table name

schema - the schema for the table

Returns:

the Table for the newly created table

getStatistics

public Map<String,FileStatistics> getStatistics(String tableName)

Parameters:

tableName - the table name

Returns:

statistics for the specified table name

getConfig

public Map<String,String> getConfig()

Returns:

the configuration for the database

sync

public SyncStatus sync(JournalContext context)
                throws IOException

Syncs the metadata from the under db. To avoid concurrent sync operations, this requires external synchronization.

Parameters:

context - journal context

Returns:

the resulting sync status

Throws:

IOException

applyAndJournal

public void applyAndJournal(java.util.function.Supplier<JournalContext> context,
                            Journal.JournalEntry entry)

Description copied from interface: Journaled

Applies and journals a journal entry. All journal appends should go through this method.

Specified by:

applyAndJournal in interface Journaled

Parameters:

context - journal context

entry - the entry to apply and journal

processJournalEntry

public boolean processJournalEntry(Journal.JournalEntry entry)

Description copied from interface: Journaled

Attempts to apply a journal entry.

Specified by:

processJournalEntry in interface Journaled

Parameters:

entry - the entry to apply

Returns:

whether the entry type is supported by this journaled object

resetState

public void resetState()

Description copied from interface: Journaled

Resets the object's journaled state.

Specified by:

resetState in interface Journaled

getJournalEntryIterator

public CloseableIterator<Journal.JournalEntry> getJournalEntryIterator()

Specified by:

getJournalEntryIterator in interface JournalEntryIterable

Returns:

an CloseableIterator that iterates all the journal entries

getCheckpointName

public CheckpointName getCheckpointName()

Specified by:

getCheckpointName in interface Checkpointed

Returns:

a name for this checkpointed class

toJournalProto

public static Table.UpdateDatabaseInfoEntry toJournalProto(DatabaseInfo dbInfo,
                                                           String dbName)

Parameters:

dbInfo - database info object

dbName - database name

Returns:

the journal proto representation