Package io.delta.kernel.internal.hook

Class LogCompactionHook

Object

io.delta.kernel.internal.hook.LogCompactionHook

All Implemented Interfaces:

PostCommitHook

public class LogCompactionHook
extends Object
implements PostCommitHook

A post-commit hook that performs inline log compaction. It merges commit JSON files over a compaction interval into a single compacted JSON file.

Nested Class Summary

Nested classes/interfaces inherited from interface io.delta.kernel.hook.PostCommitHook

PostCommitHook.PostCommitHookType

Constructor Summary

Constructors

Constructor	Description
LogCompactionHook(Path dataPath, Path logPath, long startVersion, long commitVersion, long minFileRetentionTimestampMillis)

Method Summary

Modifier and Type	Method	Description
long	getCommitVersion()
Path	getDataPath()
Path	getLogPath()
long	getMinFileRetentionTimestampMillis()
long	getStartVersion()
PostCommitHook.PostCommitHookType	getType()
void	threadSafeInvoke(Engine engine)	Invokes the post commit operation whose implementation must be thread safe.

Methods inherited from class java.lang.Object

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

Constructor Details

LogCompactionHook

public LogCompactionHook(Path dataPath,
 Path logPath,
 long startVersion,
 long commitVersion,
 long minFileRetentionTimestampMillis)

Method Details

threadSafeInvoke

public void threadSafeInvoke(Engine engine)
                      throws IOException

Description copied from interface: PostCommitHook

Invokes the post commit operation whose implementation must be thread safe.

Specified by:

threadSafeInvoke in interface PostCommitHook

Throws:

IOException

getType

public PostCommitHook.PostCommitHookType getType()

Specified by:

getType in interface PostCommitHook

getDataPath

@VisibleForTesting
public Path getDataPath()

getLogPath

@VisibleForTesting
public Path getLogPath()

getStartVersion

@VisibleForTesting
public long getStartVersion()

getCommitVersion

@VisibleForTesting
public long getCommitVersion()

getMinFileRetentionTimestampMillis

@VisibleForTesting
public long getMinFileRetentionTimestampMillis()