Package com.illumon.iris.db.util.config.tools

Class InputTableSnapshotExecutor.InputTableSnapshotRunner

java.lang.Object

com.illumon.iris.db.util.config.tools.InputTableSnapshotExecutor.InputTableSnapshotRunner

All Implemented Interfaces:

InputTableSnapshotExecutor.SnapshotRunner

Enclosing class:

InputTableSnapshotExecutor

protected abstract class InputTableSnapshotExecutor.InputTableSnapshotRunner
extends Object
implements InputTableSnapshotExecutor.SnapshotRunner

Actually executes the input table snapshot for a given namespace and table name.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	InputTableSnapshotExecutor.InputTableSnapshotRunner.FirstResultCachedFunction<T,R>	A function that reuses the first result.

Field Summary

Fields

Modifier and Type	Field	Description
protected final String	currentDate
protected final InputTableNameTarget	target

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	InputTableSnapshotRunner(@NotNull InputTableNameTarget target)

Method Summary

Modifier and Type	Method	Description
protected abstract void	addSnapshotDefinition(@NotNull String snapshotNamespace)
protected abstract String[]	getSnapshotDates(@NotNull String snapshotNamespace)
protected abstract boolean	hasSnapshotNamespace(@NotNull String snapshotNamespace)
protected abstract boolean	hasSnapshotTable(@NotNull String snapshotNamespace)
protected abstract boolean	inputTableExists()
protected abstract boolean	inputTableIsEmpty()
protected abstract int	inputTablePartitionCount()
protected abstract int	inputTablePartitionMinimum()
void	run()
protected abstract long	sizeOfChangesSinceLastSnapshot(@NotNull String snapshotNamespace)
protected abstract long	sizeOfLastSnapshot(@NotNull String snapshotNamespace)
protected abstract void	snapshotLastSnapshotAndLiveData(@NotNull String snapshotNamespace)
protected abstract void	snapshotLiveData(@NotNull String snapshotNamespace)

Methods inherited from class java.lang.Object

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

Field Details

target

protected final InputTableNameTarget target

currentDate

protected final String currentDate

Constructor Details

InputTableSnapshotRunner

protected InputTableSnapshotRunner(@NotNull
 @NotNull InputTableNameTarget target)

Method Details

inputTableExists

protected abstract boolean inputTableExists()

inputTableIsEmpty

protected abstract boolean inputTableIsEmpty()

inputTablePartitionCount

protected abstract int inputTablePartitionCount()

inputTablePartitionMinimum

protected abstract int inputTablePartitionMinimum()

hasSnapshotNamespace

protected abstract boolean hasSnapshotNamespace(@NotNull
 @NotNull String snapshotNamespace)

hasSnapshotTable

protected abstract boolean hasSnapshotTable(@NotNull
 @NotNull String snapshotNamespace)

addSnapshotDefinition

protected abstract void addSnapshotDefinition(@NotNull
 @NotNull String snapshotNamespace)

getSnapshotDates

protected abstract String[] getSnapshotDates(@NotNull
 @NotNull String snapshotNamespace)

snapshotLiveData

protected abstract void snapshotLiveData(@NotNull
 @NotNull String snapshotNamespace)

sizeOfChangesSinceLastSnapshot

protected abstract long sizeOfChangesSinceLastSnapshot(@NotNull
 @NotNull String snapshotNamespace)

sizeOfLastSnapshot

protected abstract long sizeOfLastSnapshot(@NotNull
 @NotNull String snapshotNamespace)

snapshotLastSnapshotAndLiveData

protected abstract void snapshotLastSnapshotAndLiveData(@NotNull
 @NotNull String snapshotNamespace)

run

public void run()

Specified by:

run in interface InputTableSnapshotExecutor.SnapshotRunner