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

Class InputTableSnapshotExecutor

java.lang.Object

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

public abstract class InputTableSnapshotExecutor
extends Object

Abstracts input table snapshot execution for both Legacy and Core+.

Organized to support Legacy's partial client, partial server compute via CARQ as well as Core+ fully on server.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	InputTableSnapshotExecutor.InputTableNamespaceSnapshotRunner	Actually executes the input table snapshots given a namespace.
protected class	InputTableSnapshotExecutor.InputTableSnapshotRunner	Actually executes the input table snapshot for a given namespace and table name.
protected static interface	InputTableSnapshotExecutor.SnapshotRunner	Actually runs the snapshot logic.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SNAPSHOT_NAMESPACE_SUFFIX

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	InputTableSnapshotExecutor(int daysSinceLastSnapshotThreshold, double changesToSnapshotSizeRatioThreshold, com.fishlib.io.logger.Logger log, DbAclWriteClient aclWriter)

Method Summary

Modifier and Type	Method	Description
Result	computeResult(List<? extends InputTableTarget> snapshotTargets)	Execute snapshots for each given snapshot target.
protected abstract InputTableSnapshotExecutor.InputTableNamespaceSnapshotRunner	makeInputTableNamespaceSnapshotRunner(InputTableNamespaceTarget inputTableNamespaceSnapshotTarget)
protected abstract InputTableSnapshotExecutor.InputTableSnapshotRunner	makeInputTableSnapshotRunner(InputTableNameTarget inputTableSnapshotTarget)

Methods inherited from class java.lang.Object

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

Field Details

SNAPSHOT_NAMESPACE_SUFFIX

public static final String SNAPSHOT_NAMESPACE_SUFFIX

See Also:

• Constant Field Values

Constructor Details

InputTableSnapshotExecutor

protected InputTableSnapshotExecutor(int daysSinceLastSnapshotThreshold,
 double changesToSnapshotSizeRatioThreshold,
 @NotNull
 com.fishlib.io.logger.Logger log,
 @NotNull
 DbAclWriteClient aclWriter)

Method Details

makeInputTableSnapshotRunner

protected abstract InputTableSnapshotExecutor.InputTableSnapshotRunner makeInputTableSnapshotRunner(@NotNull
 InputTableNameTarget inputTableSnapshotTarget)

makeInputTableNamespaceSnapshotRunner

protected abstract InputTableSnapshotExecutor.InputTableNamespaceSnapshotRunner makeInputTableNamespaceSnapshotRunner(@NotNull
 InputTableNamespaceTarget inputTableNamespaceSnapshotTarget)

computeResult

public Result computeResult(@NotNull
 List<? extends InputTableTarget> snapshotTargets)

Execute snapshots for each given snapshot target.

Parameters:

snapshotTargets - targets to snapshot

Returns:

the result of the snapshot execution