Skip to content

Commit 50e061f

Browse files
committed
expose reload executor from table data manager
1 parent dcbe2ae commit 50e061f

2 files changed

Lines changed: 11 additions & 0 deletions

File tree

pinot-core/src/main/java/org/apache/pinot/core/data/manager/BaseTableDataManager.java

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -758,6 +758,11 @@ public ExecutorService getSegmentPreloadExecutor() {
758758
return _segmentPreloadExecutor;
759759
}
760760

761+
@Override
762+
public ExecutorService getSegmentReloadRefreshExecutor() {
763+
return _segmentReloadRefreshExecutor;
764+
}
765+
761766
@Override
762767
public boolean isDeleted() {
763768
return _isDeleted;

pinot-segment-local/src/main/java/org/apache/pinot/segment/local/data/manager/TableDataManager.java

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -297,6 +297,12 @@ default List<SegmentDataManager> acquireSegments(List<String> segmentNames,
297297
*/
298298
ExecutorService getSegmentPreloadExecutor();
299299

300+
/**
301+
* Returns the executor used for segment reload and refresh operations.
302+
* Can be used to submit work that should run with the same concurrency controls as segment reloads.
303+
*/
304+
ExecutorService getSegmentReloadRefreshExecutor();
305+
300306
/**
301307
* Add error related to segment, if any. The implementation
302308
* is expected to cache last 'N' errors for the table, related to

0 commit comments

Comments
 (0)