public class TransportBulkAction extends HandledTransportAction<BulkRequest,BulkResponse>
TransportShardBulkAction
for shard-level bulk executiondeprecationLogger, logger, settings
actionName, indexNameExpressionResolver, taskManager, threadPool
Constructor | Description |
---|---|
TransportBulkAction(Settings settings,
ThreadPool threadPool,
TransportService transportService,
ClusterService clusterService,
IngestService ingestService,
TransportShardBulkAction shardBulkAction,
TransportCreateIndexAction createIndexAction,
ActionFilters actionFilters,
IndexNameExpressionResolver indexNameExpressionResolver,
AutoCreateIndex autoCreateIndex) |
|
TransportBulkAction(Settings settings,
ThreadPool threadPool,
TransportService transportService,
ClusterService clusterService,
IngestService ingestService,
TransportShardBulkAction shardBulkAction,
TransportCreateIndexAction createIndexAction,
ActionFilters actionFilters,
IndexNameExpressionResolver indexNameExpressionResolver,
AutoCreateIndex autoCreateIndex,
java.util.function.LongSupplier relativeTimeProvider) |
Modifier and Type | Method | Description |
---|---|---|
protected void |
doExecute(BulkRequest bulkRequest,
ActionListener<BulkResponse> listener) |
|
protected void |
doExecute(Task task,
BulkRequest bulkRequest,
ActionListener<BulkResponse> listener) |
logDeprecatedSetting, logRemovedSetting, nodeName
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
execute, execute, execute, execute
@Inject public TransportBulkAction(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterService clusterService, IngestService ingestService, TransportShardBulkAction shardBulkAction, TransportCreateIndexAction createIndexAction, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, AutoCreateIndex autoCreateIndex)
public TransportBulkAction(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterService clusterService, IngestService ingestService, TransportShardBulkAction shardBulkAction, TransportCreateIndexAction createIndexAction, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, AutoCreateIndex autoCreateIndex, java.util.function.LongSupplier relativeTimeProvider)
protected final void doExecute(BulkRequest bulkRequest, ActionListener<BulkResponse> listener)
doExecute
in class TransportAction<BulkRequest,BulkResponse>
protected void doExecute(Task task, BulkRequest bulkRequest, ActionListener<BulkResponse> listener)
doExecute
in class TransportAction<BulkRequest,BulkResponse>