public class TransportFlushAction extends TransportBroadcastReplicationAction<FlushRequest,FlushResponse,ShardFlushRequest,ReplicationResponse>
actionName, indexNameExpressionResolver, taskManager, threadPool
deprecationLogger, logger, settings
Constructor and Description |
---|
TransportFlushAction(Settings settings,
ThreadPool threadPool,
ClusterService clusterService,
TransportService transportService,
ActionFilters actionFilters,
IndexNameExpressionResolver indexNameExpressionResolver,
TransportShardFlushAction replicatedFlushAction) |
Modifier and Type | Method and Description |
---|---|
protected FlushResponse |
newResponse(int successfulShards,
int failedShards,
int totalNumCopies,
java.util.List<ShardOperationFailedException> shardFailures) |
protected ShardFlushRequest |
newShardRequest(FlushRequest request,
ShardId shardId) |
protected ReplicationResponse |
newShardResponse() |
doExecute, doExecute, shardExecute, shards
execute, execute, execute, execute
logDeprecatedSetting, logRemovedSetting, nodeName
@Inject public TransportFlushAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, TransportShardFlushAction replicatedFlushAction)
protected ReplicationResponse newShardResponse()
newShardResponse
in class TransportBroadcastReplicationAction<FlushRequest,FlushResponse,ShardFlushRequest,ReplicationResponse>
protected ShardFlushRequest newShardRequest(FlushRequest request, ShardId shardId)
newShardRequest
in class TransportBroadcastReplicationAction<FlushRequest,FlushResponse,ShardFlushRequest,ReplicationResponse>
protected FlushResponse newResponse(int successfulShards, int failedShards, int totalNumCopies, java.util.List<ShardOperationFailedException> shardFailures)
newResponse
in class TransportBroadcastReplicationAction<FlushRequest,FlushResponse,ShardFlushRequest,ReplicationResponse>