Package com.illumon.iris.db.tables.dataimport.importstate.lastby

Class LastByTableImportState<KEY_TYPE>

java.lang.Object

com.illumon.iris.db.tables.dataimport.importstate.TupleKeyedAbstractImportState<KEY_TYPE>

com.illumon.iris.db.tables.dataimport.importstate.lastby.BaseLastByTableImportState<KEY_TYPE>

com.illumon.iris.db.tables.dataimport.importstate.lastby.LastByTableImportState<KEY_TYPE>

All Implemented Interfaces:

ImportState, LiveTable, Externalizable, Serializable, Runnable

public class LastByTableImportState<KEY_TYPE>
extends BaseLastByTableImportState<KEY_TYPE>

ImportState that publishes a last-by view of the data being imported, producing a table intended for concurrent usage by clients with access to the importing process.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	LastByTableImportState.ResultTableMap	LocalTableMap with an associated LiveTableRefreshCombiner.

Nested classes/interfaces inherited from class com.illumon.iris.db.tables.dataimport.importstate.lastby.BaseLastByTableImportState

BaseLastByTableImportState.RowSetFactoryAdapter

Constructor Summary

Constructors

Constructor	Description
LastByTableImportState()	Constructor for an empty import state with null name.
LastByTableImportState(String name)	Constructor for an empty import state.

Method Summary

Modifier and Type	Method	Description
void	ensureInitialized(FullTableLocationKey locationKey)	Called when non-import code needs to ensure that an ImportState's internals have been initialized because of their side effects.
protected BaseLastByTableImportState.RowSetFactoryAdapter	getRowSetFactoryAdapter()	Get the builder suitable for creating an initial RowSet (or Index) for this engine.
static LastByTableImportState.ResultTableMap	getTableMap(TableKey tableKey)	Get a LocalTableMap keyed by TableLocationKey of DynamicTables that contain only an Index and no user-facing ColumnSources.
static LastByTableImportState.ResultTableMap	getTableMap(TableKey tableKey, String name)	Get a LocalTableMap keyed by TableLocationKey of DynamicTables that contain only an Index and no user-facing ColumnSources.
protected boolean	isValidToRefresh()	Verify that this state remains valid for refreshing.
protected void	maybeUpdate(long[] addedKeys, long[] removedKeys)	Update the table if we remain the owner of the ImportState
void	onResume(FullTableLocationKey locationKey)	Called when data ingestion is resumed for the location observed by this ImportState.
void	onTruncate(FullTableLocationKey locationKey)	Called when the underlying table location has been truncated.
protected void	startRefreshing()
protected void	stopRefreshing()

Methods inherited from class com.illumon.iris.db.tables.dataimport.importstate.lastby.BaseLastByTableImportState

getImportDetails, getName, newRowForKey, onClose, onFlush, onRelease, readExternal, refresh, skipRow, writeExternal

Methods inherited from class com.illumon.iris.db.tables.dataimport.importstate.TupleKeyedAbstractImportState

newRow, newRow, newRow, newRow, prepareElement, prepareKey

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.db.tables.live.LiveTable

run

Constructor Details

LastByTableImportState

public LastByTableImportState()

Constructor for an empty import state with null name.

LastByTableImportState

public LastByTableImportState(String name)

Constructor for an empty import state.

Parameters:

name - The name for this last-by view (see getTableMap(TableKey, String)).

Method Details

getTableMap

public static LastByTableImportState.ResultTableMap getTableMap(@NotNull
 TableKey tableKey)

Get a LocalTableMap keyed by TableLocationKey of DynamicTables that contain only an Index and no user-facing ColumnSources. The contents of the result are produced by LastByImportState instances for the supplied TableKey and null name

Parameters:

tableKey - The key

Returns:

The table map, possibly empty

getTableMap

public static LastByTableImportState.ResultTableMap getTableMap(@NotNull
 TableKey tableKey,
 String name)

Get a LocalTableMap keyed by TableLocationKey of DynamicTables that contain only an Index and no user-facing ColumnSources. The contents of the result are produced by LastByTableImportState instances for the supplied TableKey and name. Distinct names should be used for distinct last-by import state views of the same table. TODO: Consider whether we should implement a LocalTableMap equivalent that stores weakly-reachable values.

Parameters:

tableKey - The key

name - The name

Returns:

The table map, possibly empty

getRowSetFactoryAdapter

protected BaseLastByTableImportState.RowSetFactoryAdapter getRowSetFactoryAdapter()

Description copied from class: BaseLastByTableImportState

Get the builder suitable for creating an initial RowSet (or Index) for this engine.

Specified by:

getRowSetFactoryAdapter in class BaseLastByTableImportState<KEY_TYPE>

Returns:

the RowSetAdapter for this concrete state.

ensureInitialized

public void ensureInitialized(@NotNull
 FullTableLocationKey locationKey)

Description copied from interface: ImportState

Called when non-import code needs to ensure that an ImportState's internals have been initialized because of their side effects. Must not interfere with concurrent data ingestion in the same process. Generally should be treated as a query operation, and the caller should hold the LiveTableMonitor lock.

Specified by:

ensureInitialized in interface ImportState

Specified by:

ensureInitialized in class BaseLastByTableImportState<KEY_TYPE>

Parameters:

locationKey - The full table location key of the location whose ImportState is being initialized

onResume

public void onResume(@NotNull
 FullTableLocationKey locationKey)

Description copied from interface: ImportState

Called when data ingestion is resumed for the location observed by this ImportState.

Specified by:

onResume in interface ImportState

Specified by:

onResume in class BaseLastByTableImportState<KEY_TYPE>

Parameters:

locationKey - The full table location key of the location that has been resumed

onTruncate

public void onTruncate(@NotNull
 FullTableLocationKey locationKey)

Description copied from interface: ImportState

Called when the underlying table location has been truncated. Useful for resetting any in-memory state that may otherwise linger inappropriately.

Specified by:

onTruncate in interface ImportState

Overrides:

onTruncate in class BaseLastByTableImportState<KEY_TYPE>

Parameters:

locationKey - The full table location key of the location that has been truncated

startRefreshing

protected void startRefreshing()

Specified by:

startRefreshing in class BaseLastByTableImportState<KEY_TYPE>

stopRefreshing

protected void stopRefreshing()

Specified by:

stopRefreshing in class BaseLastByTableImportState<KEY_TYPE>

isValidToRefresh

protected boolean isValidToRefresh()

Description copied from class: BaseLastByTableImportState

Verify that this state remains valid for refreshing.

Specified by:

isValidToRefresh in class BaseLastByTableImportState<KEY_TYPE>

Returns:

true if this state is valid for refreshing.

maybeUpdate

protected void maybeUpdate(long[] addedKeys,
 long[] removedKeys)

Description copied from class: BaseLastByTableImportState

Update the table if we remain the owner of the ImportState

Specified by:

maybeUpdate in class BaseLastByTableImportState<KEY_TYPE>

Parameters:

addedKeys - row keys (positions in this partition) added to the table

removedKeys - row keys (positions in this partition) removed from the table