public class PerSessionDirectoryFactory extends Object implements ReplicationClient.SourceDirectoryFactory
ReplicationClient.SourceDirectoryFactory which returns FSDirectory under a
dedicated session directory. When a session is over, the entire directory is
deleted.| Constructor and Description |
|---|
PerSessionDirectoryFactory(Path workDir)
Constructor with the given sources mapping.
|
| Modifier and Type | Method and Description |
|---|---|
void |
cleanupSession(String sessionID)
Called to denote that the replication actions for this session were finished and the directory is no longer needed.
|
Directory |
getDirectory(String sessionID,
String source)
Returns the
Directory to use for the given session and source. |
public PerSessionDirectoryFactory(Path workDir)
public Directory getDirectory(String sessionID, String source) throws IOException
ReplicationClient.SourceDirectoryFactoryDirectory to use for the given session and source.
Implementations may e.g. return different directories for different
sessions, or the same directory for all sessions. In that case, it is
advised to clean the directory before it is used for a new session.getDirectory in interface ReplicationClient.SourceDirectoryFactoryIOExceptionReplicationClient.SourceDirectoryFactory.cleanupSession(String)public void cleanupSession(String sessionID) throws IOException
ReplicationClient.SourceDirectoryFactorycleanupSession in interface ReplicationClient.SourceDirectoryFactoryIOExceptionCopyright © 2000-2024 Apache Software Foundation. All Rights Reserved.