We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 58f0235 commit abe574fCopy full SHA for abe574f
core/src/main/java/org/elasticsearch/cluster/service/TaskBatching.java
@@ -44,9 +44,10 @@
44
*/
45
public abstract class TaskBatching {
46
47
- protected final Logger logger;
48
- protected final ThreadPool threadPool;
49
- protected final PrioritizedEsThreadPoolExecutor threadExecutor;
+ private final Logger logger;
+ private final ThreadPool threadPool;
+ private final PrioritizedEsThreadPoolExecutor threadExecutor;
50
+ // package visible for tests
51
final Map<Object, LinkedHashSet<BatchingTask>> tasksPerExecutor = new HashMap<>();
52
53
public TaskBatching(Logger logger, PrioritizedEsThreadPoolExecutor threadExecutor, ThreadPool threadPool) {
0 commit comments