org.elasticsearch.index.shard.service
Interface IndexShard

All Superinterfaces:

IndexShardComponent

All Known Implementing Classes:

InternalIndexShard

public interface IndexShard
extends IndexShardComponent

Method Summary

ParsedDocument	create(Engine.Create create)
void	delete(Engine.Delete delete)
void	deleteByQuery(Engine.DeleteByQuery deleteByQuery)
DocsStats	docStats()
void	flush(Engine.Flush flush)
FlushStats	flushStats()
Engine.GetResult	get(Engine.Get get)
ShardGetService	getService()
GetStats	getStats()
boolean	ignoreRecoveryAttempt() Returns true if this shard can ignore a recovery attempt made to it (since the already doing/done it)
ParsedDocument	index(Engine.Index index)
ShardIndexingService	indexingService()
IndexingStats	indexingStats(String... types)
MergeStats	mergeStats()
void	optimize(Engine.Optimize optimize)
Engine.Create	prepareCreate(SourceToParse source)
Engine.Delete	prepareDelete(String type, String id, long version)
Engine.DeleteByQuery	prepareDeleteByQuery(BytesReference querySource, String[] filteringAliases, String... types)
Engine.Index	prepareIndex(SourceToParse source)
void	recover(Engine.RecoveryHandler recoveryHandler)
void	refresh(Engine.Refresh refresh)
RefreshStats	refreshStats()
ShardRouting	routingEntry()
Engine.Searcher	searcher()
ShardSearchService	searchService()
SearchStats	searchStats(String... groups)
<T> T	snapshot(Engine.SnapshotHandler<T> snapshotHandler)
IndexShardState	state()
StoreStats	storeStats()
ShardIndexWarmerService	warmerService()
WarmerStats	warmerStats()

Methods inherited from interface org.elasticsearch.index.shard.IndexShardComponent

indexSettings, shardId

Method Detail

indexingService

ShardIndexingService indexingService()

getService

ShardGetService getService()

searchService

ShardSearchService searchService()

warmerService

ShardIndexWarmerService warmerService()

routingEntry

ShardRouting routingEntry()

docStats

DocsStats docStats()

storeStats

StoreStats storeStats()

indexingStats

IndexingStats indexingStats(String... types)

searchStats

SearchStats searchStats(String... groups)

getStats

GetStats getStats()

mergeStats

MergeStats mergeStats()

refreshStats

RefreshStats refreshStats()

flushStats

FlushStats flushStats()

warmerStats

WarmerStats warmerStats()

state

IndexShardState state()

prepareCreate

Engine.Create prepareCreate(SourceToParse source)
                            throws ElasticSearchException

Throws:

ElasticSearchException

create

ParsedDocument create(Engine.Create create)
                      throws ElasticSearchException

Throws:

ElasticSearchException

prepareIndex

Engine.Index prepareIndex(SourceToParse source)
                          throws ElasticSearchException

Throws:

ElasticSearchException

index

ParsedDocument index(Engine.Index index)
                     throws ElasticSearchException

Throws:

ElasticSearchException

prepareDelete

Engine.Delete prepareDelete(String type,
                            String id,
                            long version)
                            throws ElasticSearchException

Throws:

ElasticSearchException

delete

void delete(Engine.Delete delete)
            throws ElasticSearchException

Throws:

ElasticSearchException

prepareDeleteByQuery

Engine.DeleteByQuery prepareDeleteByQuery(BytesReference querySource,
                                          @Nullable
                                          String[] filteringAliases,
                                          String... types)
                                          throws ElasticSearchException

Throws:

ElasticSearchException

deleteByQuery

void deleteByQuery(Engine.DeleteByQuery deleteByQuery)
                   throws ElasticSearchException

Throws:

ElasticSearchException

get

Engine.GetResult get(Engine.Get get)
                     throws ElasticSearchException

Throws:

ElasticSearchException

refresh

void refresh(Engine.Refresh refresh)
             throws ElasticSearchException

Throws:

ElasticSearchException

flush

void flush(Engine.Flush flush)
           throws ElasticSearchException

Throws:

ElasticSearchException

optimize

void optimize(Engine.Optimize optimize)
              throws ElasticSearchException

Throws:

ElasticSearchException

snapshot

<T> T snapshot(Engine.SnapshotHandler<T> snapshotHandler)
           throws EngineException

Throws:

EngineException

recover

void recover(Engine.RecoveryHandler recoveryHandler)
             throws EngineException

Throws:

EngineException

searcher

Engine.Searcher searcher()

ignoreRecoveryAttempt

boolean ignoreRecoveryAttempt()

Returns true if this shard can ignore a recovery attempt made to it (since the already doing/done it)