Package com.illumon.iris.db.tables.databases

Class OnDiskDatabaseUtil

java.lang.Object

com.illumon.iris.db.tables.databases.OnDiskDatabaseUtil

@InternalUseOnly
public final class OnDiskDatabaseUtil
extends Object

Functionality factored out of OnDiskDatabase, OnDiskQueryDatabase, and related classes, exposed for other database implementations.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_RTA_INTERNAL_PARTITION_STRING

Method Summary

Modifier and Type	Method	Description
static void	assertSplayed(TableDefinition tableDef, String operation)
static boolean	deleteColumnPartition(LocalTablePathManager locationManager, TableDefinitionSchema schema, String internalPartitionValue, String columnPartitionValue)
static boolean	deleteTable(TableDefinitionSchema schema, LocalTablePathManager locationManager)
static Schema	getRequiredSchema(String namespace, String tableName, SchemaService schemaService)	Get the requested schema, and throw SchemaNotFoundException if it is null.
static TableDefinitionSchema	getRequiredTableDefinitionSchema(String namespace, String tableName, SchemaService schemaService)	Get the requested schema, and throw SchemaNotFoundException if it is null.
static File	getTableLockFile(TableDefinitionSchema table, LocalTablePathManager locationManager)	Create and return a table data lock file.
static MutableSchema	makeMutableSchemaFromDefinition(TableDefinition tableDef, String namespace, String tableName, int storageType, boolean getWritable, SchemaService schemaService, NamespaceSet newNamespaceSet)
static TableDefinitionSchema	makeSchemaFromDefinition(TableDefinition tableDef, String namespace, String tableName, int storageType, boolean getWritable, SchemaService schemaService, NamespaceSet newNamespaceSet)
static <T> void	maybeCreateUserNamespace(String namespace, String tableName, SchemaService schemaService, Class<T> clazz)

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_RTA_INTERNAL_PARTITION_STRING

public static final String DEFAULT_RTA_INTERNAL_PARTITION_STRING

See Also:

• Constant Field Values

Method Details

getTableLockFile

public static File getTableLockFile(TableDefinitionSchema table,
 LocalTablePathManager locationManager)

Create and return a table data lock file.

Parameters:

table - schema

locationManager - used to ascertain metadata location

Returns:

the table data lock file handle

makeMutableSchemaFromDefinition

public static MutableSchema makeMutableSchemaFromDefinition(TableDefinition tableDef,
 String namespace,
 String tableName,
 int storageType,
 boolean getWritable,
 SchemaService schemaService,
 NamespaceSet newNamespaceSet)

makeSchemaFromDefinition

public static TableDefinitionSchema makeSchemaFromDefinition(TableDefinition tableDef,
 String namespace,
 String tableName,
 int storageType,
 boolean getWritable,
 SchemaService schemaService,
 NamespaceSet newNamespaceSet)

assertSplayed

public static void assertSplayed(TableDefinition tableDef,
 String operation)

deleteColumnPartition

public static boolean deleteColumnPartition(LocalTablePathManager locationManager,
 TableDefinitionSchema schema,
 String internalPartitionValue,
 String columnPartitionValue)

deleteTable

public static boolean deleteTable(TableDefinitionSchema schema,
 LocalTablePathManager locationManager)

maybeCreateUserNamespace

public static <T> void maybeCreateUserNamespace(String namespace,
 String tableName,
 SchemaService schemaService,
 Class<T> clazz)

getRequiredTableDefinitionSchema

@NotNull
public static TableDefinitionSchema getRequiredTableDefinitionSchema(String namespace,
 String tableName,
 SchemaService schemaService)

Get the requested schema, and throw SchemaNotFoundException if it is null.

Parameters:

namespace - the schema namespace

tableName - the schema table name

schemaService - schema service to get the schema from

Returns:

a TableDefinitionSchema

Throws:

SchemaNotFoundException - if the schema is not found

getRequiredSchema

@NotNull
public static Schema getRequiredSchema(@NotNull
 String namespace,
 @NotNull
 String tableName,
 @NotNull
 SchemaService schemaService)

Get the requested schema, and throw SchemaNotFoundException if it is null.

Parameters:

namespace - the schema namespace

tableName - the schema table name

schemaService - schema service to get the schema from

Returns:

a Schema

Throws:

SchemaNotFoundException - if the schema is not found