keith-turner commented on code in PR #5987:
URL: https://github.com/apache/accumulo/pull/5987#discussion_r2550865007
##########
server/tserver/src/main/java/org/apache/accumulo/tserver/TabletServerResourceManager.java:
##########
@@ -784,23 +763,50 @@ public void close() throws IOException {
}
}
}
+
+ public TabletServerResourceManager getTabletServerResourceManager() {
+ return TabletServerResourceManager.this;
+ }
+ }
+
+ public void executeSplit(KeyExtent tablet, Runnable splitTask) {
+ if (tablet.isMeta()) {
+ if (tablet.isRootTablet()) {
+ log.warn("Saw request to split root tablet, ignoring");
+ return;
+ }
+ defaultSplitThreadPool.execute(splitTask);
+ } else {
+ splitThreadPool.execute(splitTask);
+ }
+ }
+
+ @SuppressWarnings("deprecation")
+ private static abstract class DispatchParamsImpl implements
DispatchParameters,
+ org.apache.accumulo.core.spi.scan.ScanDispatcher.DispatchParmaters {
+
}
+ private static final ScanDispatch ROOT_SCAN_DISPATCH =
+ ScanDispatch.builder().setExecutorName("root").build();
+ private static final ScanDispatch META_SCAN_DISPATCH =
+ ScanDispatch.builder().setExecutorName("meta").build();
+
public void executeReadAhead(KeyExtent tablet, ScanDispatcher dispatcher,
ScanSession<?> scanInfo,
Runnable task) {
task = ScanSession.wrap(scanInfo, task);
if (tablet.isRootTablet()) {
// TODO make meta dispatch??
Review Comment:
For user tables plugins can dispatch their scans to different executors.
For the metadata and root tablets it hard coded which executors they will use
for scans. Those comments are about those diffs.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
