Package com.illumon.iris.db.v2.locations.local

Class LocalMetadataIndexer

java.lang.Object

com.illumon.iris.db.v2.locations.local.LocalMetadataIndexer

public class LocalMetadataIndexer
extends Object

Local metadata indexing tool.

Field Summary

Fields

Modifier and Type	Field	Description
static final boolean	ENABLED

Constructor Summary

Constructors

Constructor	Description
LocalMetadataIndexer()

Method Summary

Modifier and Type	Method	Description
static void	main(String... args)
static Table	metadataTable(OnDiskQueryDatabase db, String namespace, String tableName)
static Table	metadataTable(TableLookupKey tlk, LocalTablePathManager ltpm, TableLocationMetadataIndex mdi)
static Table	metadataTable(TableLookupKey tlk, LocalTablePathManager ltpm, Collection<TableLocationMetadataIndex.TableLocationSnapshot> tableLocationSnapshots)
static TableLocationMetadataIndex	readTableLocationMetadataIndex(LocalTablePathManager pathManager, TableKey tableKey)	Read the TableLocationMetadataIndex file for the supplied table key.
static void	updateIndex(LocalTableDataService service, TableKey tableKey)	Update the persistent TableLocationMetadataIndex for the specified TableKey.
static void	writeTableLocationMetadataIndex(LocalTablePathManager pathManager, TableKey tableKey, TableLocationMetadataIndex tableLocationMetadataIndex)	Write a TableLocationMetadataIndex file for the supplied TableKey and index.
static void	writeTableLocationMetadataIndex(LocalTablePathManager pathManager, TableKey tableKey, Collection<TableLocation> tableLocations)	Write a TableLocationMetadataIndex file for the supplied TableKey and TableLocations.

Methods inherited from class java.lang.Object

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

Field Details

ENABLED

public static final boolean ENABLED

Constructor Details

LocalMetadataIndexer

public LocalMetadataIndexer()

Method Details

updateIndex

public static void updateIndex(@NotNull
 LocalTableDataService service,
 @NotNull
 TableKey tableKey)

Update the persistent TableLocationMetadataIndex for the specified TableKey.

Parameters:

service - The source for table location information

tableKey - The table key

writeTableLocationMetadataIndex

public static void writeTableLocationMetadataIndex(@NotNull
 LocalTablePathManager pathManager,
 @NotNull
 TableKey tableKey,
 @NotNull
 TableLocationMetadataIndex tableLocationMetadataIndex)

Write a TableLocationMetadataIndex file for the supplied TableKey and index.

Parameters:

pathManager - The path manager

tableKey - The table key

tableLocationMetadataIndex - The index

writeTableLocationMetadataIndex

public static void writeTableLocationMetadataIndex(@NotNull
 LocalTablePathManager pathManager,
 @NotNull
 TableKey tableKey,
 @NotNull
 Collection<TableLocation> tableLocations)

Write a TableLocationMetadataIndex file for the supplied TableKey and TableLocations.

Parameters:

pathManager - The path manager

tableKey - The table key

tableLocations - The locations

readTableLocationMetadataIndex

@Nullable
public static TableLocationMetadataIndex readTableLocationMetadataIndex(@NotNull
 LocalTablePathManager pathManager,
 @NotNull
 TableKey tableKey)

Read the TableLocationMetadataIndex file for the supplied table key.

Parameters:

pathManager - The path manager

tableKey - The table key

Returns:

The index if the file was found and readable, else null

metadataTable

public static Table metadataTable(@NotNull
 OnDiskQueryDatabase db,
 @NotNull
 String namespace,
 @NotNull
 String tableName)

metadataTable

public static Table metadataTable(TableLookupKey tlk,
 LocalTablePathManager ltpm,
 TableLocationMetadataIndex mdi)

metadataTable

public static Table metadataTable(TableLookupKey tlk,
 LocalTablePathManager ltpm,
 Collection<TableLocationMetadataIndex.TableLocationSnapshot> tableLocationSnapshots)

main

public static void main(@NotNull
 String... args)