Module org.elasticsearch.server

Package org.elasticsearch.repositories

Class LocalPrimarySnapshotShardContext

java.lang.Object

org.elasticsearch.action.DelegatingActionListener<ShardSnapshotResult,ShardSnapshotResult>

org.elasticsearch.repositories.SnapshotShardContext

org.elasticsearch.repositories.LocalPrimarySnapshotShardContext

All Implemented Interfaces:

ActionListener<ShardSnapshotResult>

public final class LocalPrimarySnapshotShardContext
extends SnapshotShardContext

A SnapshotShardContext implementation that reads data from a local primary shard for snapshotting.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.repositories.SnapshotShardContext

SnapshotShardContext.FileReader, SnapshotShardContext.IndexInputFileReader

Field Summary

Fields inherited from class org.elasticsearch.action.DelegatingActionListener

delegate

Constructor Summary

Constructors

Constructor	Description
LocalPrimarySnapshotShardContext(Store store, MapperService mapperService, SnapshotId snapshotId, IndexId indexId, SnapshotIndexCommit commitRef, String shardStateIdentifier, IndexShardSnapshotStatus snapshotStatus, IndexVersion repositoryMetaVersion, long snapshotStartTime, ActionListener<ShardSnapshotResult> listener)

Method Summary

Modifier and Type	Method	Description
boolean	assertFileContentsMatchHash(BlobStoreIndexShardSnapshot.FileInfo fileInfo)
void	failStoreIfCorrupted(Exception e)
Collection<String>	fileNames()
SnapshotShardContext.FileReader	fileReader(String file, StoreFileMetadata metadata)
org.apache.lucene.index.IndexCommit	indexCommit()
boolean	isSearchableSnapshot()
MapperService	mapperService()
Store.MetadataSnapshot	metadataSnapshot()
ShardId	shardId()
Store	store()
Releasable	withCommitRef()

Methods inherited from class org.elasticsearch.repositories.SnapshotShardContext

addListener, getRepositoryMetaVersion, indexId, onResponse, snapshotId, snapshotStartTime, stateIdentifier, status

Methods inherited from class org.elasticsearch.action.DelegatingActionListener

onFailure, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.action.ActionListener

delegateFailure, delegateFailureAndWrap, delegateFailureIgnoreResponseAndWrap, delegateResponse, map, safeMap

Constructor Details

LocalPrimarySnapshotShardContext

public LocalPrimarySnapshotShardContext(Store store,
 MapperService mapperService,
 SnapshotId snapshotId,
 IndexId indexId,
 SnapshotIndexCommit commitRef,
 @Nullable
 String shardStateIdentifier,
 IndexShardSnapshotStatus snapshotStatus,
 IndexVersion repositoryMetaVersion,
 long snapshotStartTime,
 ActionListener<ShardSnapshotResult> listener)

Parameters:

store - store to be snapshotted

mapperService - the shards mapper service

snapshotId - snapshot id

indexId - id for the index being snapshotted

commitRef - commit point reference

shardStateIdentifier - a unique identifier of the state of the shard that is stored with the shard's snapshot and used to detect if the shard has changed between snapshots. If null is passed as the identifier snapshotting will be done by inspecting the physical files referenced by snapshotIndexCommit

snapshotStatus - snapshot status

repositoryMetaVersion - version of the updated repository metadata to write

snapshotStartTime - start time of the snapshot found in SnapshotsInProgress.Entry.startTime()

listener - listener invoked on completion

Method Details

shardId

public ShardId shardId()

Specified by:

shardId in class SnapshotShardContext

store

public Store store()

mapperService

public MapperService mapperService()

indexCommit

public org.apache.lucene.index.IndexCommit indexCommit()

withCommitRef

public Releasable withCommitRef()

isSearchableSnapshot

public boolean isSearchableSnapshot()

Specified by:

isSearchableSnapshot in class SnapshotShardContext

metadataSnapshot

public Store.MetadataSnapshot metadataSnapshot()

Specified by:

metadataSnapshot in class SnapshotShardContext

fileNames

public Collection<String> fileNames()

Specified by:

fileNames in class SnapshotShardContext

assertFileContentsMatchHash

public boolean assertFileContentsMatchHash(BlobStoreIndexShardSnapshot.FileInfo fileInfo)

Specified by:

assertFileContentsMatchHash in class SnapshotShardContext

failStoreIfCorrupted

public void failStoreIfCorrupted(Exception e)

Specified by:

failStoreIfCorrupted in class SnapshotShardContext

fileReader

public SnapshotShardContext.FileReader fileReader(String file,
 StoreFileMetadata metadata)
                                           throws IOException

Specified by:

fileReader in class SnapshotShardContext

Throws:

IOException