Package org.elasticsearch.action.admin.indices.flush

Class TransportFlushAction

java.lang.Object

org.elasticsearch.action.support.TransportAction<Request,Response>

org.elasticsearch.action.support.HandledTransportAction<Request,Response>

org.elasticsearch.action.support.replication.TransportBroadcastReplicationAction<FlushRequest,FlushResponse,ShardFlushRequest,ReplicationResponse>

org.elasticsearch.action.admin.indices.flush.TransportFlushAction

public class TransportFlushAction
extends TransportBroadcastReplicationAction<FlushRequest,FlushResponse,ShardFlushRequest,ReplicationResponse>

Flush Action.

Field Summary

Fields inherited from class org.elasticsearch.action.support.TransportAction

actionName, logger, taskManager

Constructor Summary

Constructors

Constructor	Description
TransportFlushAction(ClusterService clusterService, TransportService transportService, NodeClient client, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver)

Method Summary

Modifier and Type	Method	Description
protected FlushResponse	newResponse(int successfulShards, int failedShards, int totalNumCopies, List<DefaultShardOperationFailedException> shardFailures)
protected ShardFlushRequest	newShardRequest(FlushRequest request, ShardId shardId)
protected ReplicationResponse	newShardResponse()

Methods inherited from class org.elasticsearch.action.support.replication.TransportBroadcastReplicationAction

doExecute, shardExecute, shards

Methods inherited from class org.elasticsearch.action.support.TransportAction

execute

Methods inherited from class java.lang.Object

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

Constructor Details

TransportFlushAction

@Inject
public TransportFlushAction(ClusterService clusterService,
 TransportService transportService,
 NodeClient client,
 ActionFilters actionFilters,
 IndexNameExpressionResolver indexNameExpressionResolver)

Method Details

newShardResponse

protected ReplicationResponse newShardResponse()

Specified by:

newShardResponse in class TransportBroadcastReplicationAction<FlushRequest,FlushResponse,ShardFlushRequest,ReplicationResponse>

newShardRequest

protected ShardFlushRequest newShardRequest(FlushRequest request,
 ShardId shardId)

Specified by:

newShardRequest in class TransportBroadcastReplicationAction<FlushRequest,FlushResponse,ShardFlushRequest,ReplicationResponse>

newResponse

protected FlushResponse newResponse(int successfulShards,
 int failedShards,
 int totalNumCopies,
 List<DefaultShardOperationFailedException> shardFailures)

Specified by:

newResponse in class TransportBroadcastReplicationAction<FlushRequest,FlushResponse,ShardFlushRequest,ReplicationResponse>