Package org.elasticsearch.action.bulk
Class TransportBulkAction
- java.lang.Object
-
- org.elasticsearch.common.component.AbstractComponent
-
- org.elasticsearch.action.support.TransportAction<Request,Response>
-
- org.elasticsearch.action.support.HandledTransportAction<BulkRequest,BulkResponse>
-
- org.elasticsearch.action.bulk.TransportBulkAction
-
public class TransportBulkAction extends HandledTransportAction<BulkRequest,BulkResponse>
Groups bulk request items by shard, optionally creating non-existent indices and delegates toTransportShardBulkAction
for shard-level bulk execution
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.elasticsearch.action.support.HandledTransportAction
HandledTransportAction.ChannelActionListener<Response extends TransportResponse,Request extends TransportRequest>
-
-
Field Summary
-
Fields inherited from class org.elasticsearch.action.support.TransportAction
actionName, indexNameExpressionResolver, taskManager, threadPool
-
Fields inherited from class org.elasticsearch.common.component.AbstractComponent
deprecationLogger, logger, settings
-
-
Constructor Summary
Constructors 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)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
doExecute(BulkRequest bulkRequest, ActionListener<BulkResponse> listener)
protected void
doExecute(Task task, BulkRequest bulkRequest, ActionListener<BulkResponse> listener)
-
Methods inherited from class org.elasticsearch.action.support.TransportAction
execute, execute, execute, execute
-
Methods inherited from class org.elasticsearch.common.component.AbstractComponent
nodeName
-
-
-
-
Constructor Detail
-
TransportBulkAction
@Inject public TransportBulkAction(Settings settings, ThreadPool threadPool, TransportService transportService, ClusterService clusterService, IngestService ingestService, TransportShardBulkAction shardBulkAction, TransportCreateIndexAction createIndexAction, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, AutoCreateIndex autoCreateIndex)
-
TransportBulkAction
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)
-
-
Method Detail
-
doExecute
protected final void doExecute(BulkRequest bulkRequest, ActionListener<BulkResponse> listener)
- Specified by:
doExecute
in classTransportAction<BulkRequest,BulkResponse>
-
doExecute
protected void doExecute(Task task, BulkRequest bulkRequest, ActionListener<BulkResponse> listener)
- Overrides:
doExecute
in classTransportAction<BulkRequest,BulkResponse>
-
-