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(InputTableNameTarget target)

Method Summary

Modifier and Type	Method	Description
protected abstract void	addSnapshotDefinition(String snapshotNamespace)
protected abstract String[]	getSnapshotDates(String snapshotNamespace)
protected abstract boolean	hasSnapshotNamespace(String snapshotNamespace)
protected abstract boolean	hasSnapshotTable(String snapshotNamespace)
protected abstract boolean	inputTableExists()
protected abstract boolean	inputTableIsEmpty()
protected abstract int	inputTablePartitionCount()
protected abstract int	inputTablePartitionMinimum()
void	run()
protected abstract long	sizeOfChangesSinceLastSnapshot(String snapshotNamespace)
protected abstract long	sizeOfLastSnapshot(String snapshotNamespace)
protected abstract void	snapshotLastSnapshotAndLiveData(String snapshotNamespace)
protected abstract void	snapshotLiveData(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
 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
 String snapshotNamespace)

hasSnapshotTable

protected abstract boolean hasSnapshotTable(@NotNull
 String snapshotNamespace)

addSnapshotDefinition

protected abstract void addSnapshotDefinition(@NotNull
 String snapshotNamespace)

getSnapshotDates

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

snapshotLiveData

protected abstract void snapshotLiveData(@NotNull
 String snapshotNamespace)

sizeOfChangesSinceLastSnapshot

protected abstract long sizeOfChangesSinceLastSnapshot(@NotNull
 String snapshotNamespace)

sizeOfLastSnapshot

protected abstract long sizeOfLastSnapshot(@NotNull
 String snapshotNamespace)

snapshotLastSnapshotAndLiveData

protected abstract void snapshotLastSnapshotAndLiveData(@NotNull
 String snapshotNamespace)

run

public void run()

Specified by:

run in interface InputTableSnapshotExecutor.SnapshotRunner