org.apache.paimon.utils

Class FileSystemBranchManager

java.lang.Object

org.apache.paimon.utils.FileSystemBranchManager

All Implemented Interfaces:

BranchManager

public class FileSystemBranchManager
extends Object
implements BranchManager

A BranchManager implementation to manage branches via file system.

Field Summary

Fields inherited from interface org.apache.paimon.utils.BranchManager

BRANCH_PREFIX, DEFAULT_MAIN_BRANCH

Constructor Summary

Constructors

Constructor and Description
FileSystemBranchManager(FileIO fileIO, Path path, SnapshotManager snapshotManager, TagManager tagManager, SchemaManager schemaManager)

Method Summary

Modifier and Type	Method and Description
List<String>	branches()
boolean	branchExists(String branchName) Check if a branch exists.
Path	branchPath(String branchName) Return the path of a branch.
void	createBranch(String branchName)
void	createBranch(String branchName, String tagName)
void	dropBranch(String branchName)
void	fastForward(String branchName)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.paimon.utils.BranchManager

branchPath, isMainBranch, normalizeBranch

Constructor Detail

FileSystemBranchManager

public FileSystemBranchManager(FileIO fileIO,
                               Path path,
                               SnapshotManager snapshotManager,
                               TagManager tagManager,
                               SchemaManager schemaManager)

Method Detail

branchPath

public Path branchPath(String branchName)

Return the path of a branch.

createBranch

public void createBranch(String branchName)

Specified by:

createBranch in interface BranchManager

createBranch

public void createBranch(String branchName,
                         String tagName)

Specified by:

createBranch in interface BranchManager

dropBranch

public void dropBranch(String branchName)

Specified by:

dropBranch in interface BranchManager

fastForward

public void fastForward(String branchName)

Specified by:

fastForward in interface BranchManager

branchExists

public boolean branchExists(String branchName)

Check if a branch exists.

branches

public List<String> branches()

Specified by:

branches in interface BranchManager