|
40 | 40 | import org.elasticsearch.common.io.stream.Writeable; |
41 | 41 | import org.elasticsearch.common.util.concurrent.EsExecutors; |
42 | 42 | import org.elasticsearch.core.FixForMultiProject; |
| 43 | +import org.elasticsearch.core.Nullable; |
43 | 44 | import org.elasticsearch.tasks.Task; |
44 | 45 | import org.elasticsearch.tasks.TaskId; |
45 | 46 | import org.elasticsearch.transport.AbstractTransportRequest; |
|
70 | 71 | * @param <Request> the underlying client request |
71 | 72 | * @param <Response> the response to the client request |
72 | 73 | * @param <ShardOperationResult> per-shard operation results |
| 74 | + * @param <NodeContext> the optional node context created by createNodeContext and passed to shardOperation |
73 | 75 | */ |
74 | 76 | public abstract class TransportBroadcastByNodeAction< |
75 | 77 | Request extends BroadcastRequest<Request>, |
@@ -179,13 +181,14 @@ Response newResponse( |
179 | 181 | * @param request the node-level request |
180 | 182 | * @param shardRouting the shard on which to execute the operation |
181 | 183 | * @param task the task for this node-level request |
| 184 | + * @param nodeContext the context created by {{@link #createNodeContext()}} |
182 | 185 | * @param listener the listener to notify with the result of the shard-level operation |
183 | 186 | */ |
184 | 187 | protected abstract void shardOperation( |
185 | 188 | Request request, |
186 | 189 | ShardRouting shardRouting, |
187 | 190 | Task task, |
188 | | - NodeContext nodeContext, |
| 191 | + @Nullable NodeContext nodeContext, |
189 | 192 | ActionListener<ShardOperationResult> listener |
190 | 193 | ); |
191 | 194 |
|
|
0 commit comments