com.illumon.iris.db.tables.utils

Class TableManagementTools

java.lang.Object

com.illumon.iris.db.tables.utils.TableManagementTools

public class TableManagementTools
extends Object

Tools for managing and manipulating tables.

Method Summary

Modifier and Type	Method and Description
static TableDefinition	addColumns(TableDefinition currentDefinition, File rootDir, int levels, String... columnsToAdd)
static TableDefinition	addColumns(TableDefinition currentDefinition, File path, String... columnsToAdd)
static void	addGroupingMetadata(File tableDirectory)
static void	addGroupingMetadata(File tableDirectory, TableDefinition tableDefinition)
static void	appendToTable(Table tableToAppend, String destDir)
static void	appendToTables(TableDefinition definitionToAppend, Table[] tablesToAppend, String[] destinationDirectoryNames)
static void	deleteTable(File path)
static TableDefinition	dropColumns(TableDefinition currentDefinition, File rootDir, int levels, String... columnsToRemove)
static TableDefinition	dropColumns(TableDefinition currentDefinition, File path, String... columnsToRemove)
static void	flushColumnData() Flush all previously written column data to disk.
static List<File>	getAllDbDirs(String tableName, File rootDir, int levelsDepth)
static Table	readTable(File path)
static Table	readTable(File path, TableDefinition tableDefinition)
static TableDefinition	renameColumns(TableDefinition currentDefinition, File rootDir, int levels, String... columnsToRename)
static TableDefinition	renameColumns(TableDefinition currentDefinition, File path, MatchPair... columnsToRename)
static TableDefinition	renameColumns(TableDefinition currentDefinition, File path, String... columnsToRename)
static TableDefinition	updateColumns(TableDefinition currentDefinition, File rootDir, int levels, String... updates)
static <TYPE> long	writeColumn(Table sourceTable, LocalAppendableTable destinationTable, long pendingCount, com.illumon.dataobjects.ColumnDefinition columnDefinition, Map<TYPE,long[]> currentMapping, long currentSize)
static void	writeTable(Table sourceTable, File destDir)
static void	writeTable(Table sourceTable, String destDir)
static void	writeTables(Table[] sources, TableDefinition tableDefinition, File[] destinations)

Methods inherited from class java.lang.Object

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

Method Detail

readTable

public static Table readTable(@NotNull
                              File path,
                              @NotNull
                              TableDefinition tableDefinition)

readTable

public static Table readTable(@NotNull
                              File path)

writeTable

public static void writeTable(Table sourceTable,
                              String destDir)

writeTable

public static void writeTable(Table sourceTable,
                              File destDir)

writeTables

public static void writeTables(@NotNull
                               Table[] sources,
                               @NotNull
                               TableDefinition tableDefinition,
                               @NotNull
                               File[] destinations)

writeColumn

public static <TYPE> long writeColumn(@NotNull
                                      Table sourceTable,
                                      @NotNull
                                      LocalAppendableTable destinationTable,
                                      long pendingCount,
                                      @NotNull
                                      com.illumon.dataobjects.ColumnDefinition columnDefinition,
                                      @Nullable
                                      Map<TYPE,long[]> currentMapping,
                                      long currentSize)

addGroupingMetadata

public static void addGroupingMetadata(File tableDirectory)

addGroupingMetadata

public static void addGroupingMetadata(File tableDirectory,
                                       TableDefinition tableDefinition)

deleteTable

public static void deleteTable(File path)

appendToTable

public static void appendToTable(@NotNull
                                 Table tableToAppend,
                                 @NotNull
                                 String destDir)

appendToTables

public static void appendToTables(@NotNull
                                  TableDefinition definitionToAppend,
                                  @NotNull
                                  Table[] tablesToAppend,
                                  @NotNull
                                  String[] destinationDirectoryNames)

flushColumnData

public static void flushColumnData()

Flush all previously written column data to disk.

getAllDbDirs

public static List<File> getAllDbDirs(String tableName,
                                      File rootDir,
                                      int levelsDepth)

dropColumns

public static TableDefinition dropColumns(TableDefinition currentDefinition,
                                          File rootDir,
                                          int levels,
                                          String... columnsToRemove)

dropColumns

public static TableDefinition dropColumns(TableDefinition currentDefinition,
                                          File path,
                                          String... columnsToRemove)

renameColumns

public static TableDefinition renameColumns(TableDefinition currentDefinition,
                                            File rootDir,
                                            int levels,
                                            String... columnsToRename)
                                     throws IOException

Throws:

IOException

renameColumns

public static TableDefinition renameColumns(TableDefinition currentDefinition,
                                            File path,
                                            String... columnsToRename)
                                     throws IOException

Throws:

IOException

renameColumns

public static TableDefinition renameColumns(TableDefinition currentDefinition,
                                            File path,
                                            MatchPair... columnsToRename)
                                     throws IOException

Throws:

IOException

updateColumns

public static TableDefinition updateColumns(TableDefinition currentDefinition,
                                            File rootDir,
                                            int levels,
                                            String... updates)
                                     throws IOException

Throws:

IOException

addColumns

public static TableDefinition addColumns(TableDefinition currentDefinition,
                                         File rootDir,
                                         int levels,
                                         String... columnsToAdd)
                                  throws IOException

Throws:

IOException

addColumns

public static TableDefinition addColumns(TableDefinition currentDefinition,
                                         File path,
                                         String... columnsToAdd)
                                  throws IOException

Throws:

IOException