Package org.elasticsearch.repositories.blobstore

Class FileRestoreContext

java.lang.Object

org.elasticsearch.repositories.blobstore.FileRestoreContext

public abstract class FileRestoreContext
extends java.lang.Object

This context will execute a file restore of the lucene files. It is primarily designed to be used to restore from some form of a snapshot. It will setup a new store, identify files that need to be copied for the source, and perform the copies. Implementers must implement the functionality of opening the underlying file streams for snapshotted lucene file.

Field Summary

Fields

Modifier and Type	Field	Description
protected int	bufferSize
protected static org.apache.logging.log4j.Logger	logger
protected RecoveryState	recoveryState
protected java.lang.String	repositoryName
protected ShardId	shardId
protected SnapshotId	snapshotId

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FileRestoreContext(java.lang.String repositoryName, ShardId shardId, SnapshotId snapshotId, RecoveryState recoveryState, int bufferSize)	Constructs new restore context

Method Summary

Modifier and Type	Method	Description
protected abstract java.io.InputStream	fileInputStream(BlobStoreIndexShardSnapshot.FileInfo fileInfo)
void	restore(SnapshotFiles snapshotFiles, Store store)	Performs restore operation
protected void	restoreFiles(java.util.List<BlobStoreIndexShardSnapshot.FileInfo> filesToRecover, Store store)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected static final org.apache.logging.log4j.Logger logger

repositoryName

protected final java.lang.String repositoryName

recoveryState

protected final RecoveryState recoveryState

snapshotId

protected final SnapshotId snapshotId

shardId

protected final ShardId shardId

bufferSize

protected final int bufferSize

Constructor Detail

FileRestoreContext

protected FileRestoreContext(java.lang.String repositoryName,
                             ShardId shardId,
                             SnapshotId snapshotId,
                             RecoveryState recoveryState,
                             int bufferSize)

Constructs new restore context

Parameters:

shardId - shard id to restore into

snapshotId - snapshot id

recoveryState - recovery state to report progress

bufferSize - buffer size for restore

Method Detail

restore

public void restore(SnapshotFiles snapshotFiles,
                    Store store)
             throws java.io.IOException

Performs restore operation

Throws:

java.io.IOException

restoreFiles

protected void restoreFiles(java.util.List<BlobStoreIndexShardSnapshot.FileInfo> filesToRecover,
                            Store store)
                     throws java.io.IOException

Throws:

java.io.IOException

fileInputStream

protected abstract java.io.InputStream fileInputStream(BlobStoreIndexShardSnapshot.FileInfo fileInfo)