This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 49fe4f2c6e Allow custom operations after upsert preload is done
(#11259)
49fe4f2c6e is described below
commit 49fe4f2c6eeddd64161bc4d9c9dfe5fdb0c34d89
Author: Xiaotian (Jackie) Jiang <[email protected]>
AuthorDate: Wed Aug 2 21:59:03 2023 -0700
Allow custom operations after upsert preload is done (#11259)
---
.../pinot/segment/local/upsert/BaseTableUpsertMetadataManager.java | 7 +++++++
1 file changed, 7 insertions(+)
diff --git
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/BaseTableUpsertMetadataManager.java
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/BaseTableUpsertMetadataManager.java
index e23689ad09..148248b0be 100644
---
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/BaseTableUpsertMetadataManager.java
+++
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/BaseTableUpsertMetadataManager.java
@@ -175,6 +175,7 @@ public abstract class BaseTableUpsertMetadataManager
implements TableUpsertMetad
}
}
}
+ onPreloadFinish();
LOGGER.info("Preloaded segments from table: {} for fast upsert metadata
recovery", _tableNameWithType);
}
@@ -225,6 +226,12 @@ public abstract class BaseTableUpsertMetadataManager
implements TableUpsertMetad
return new File(SegmentDirectoryPaths.findSegmentDirectory(indexDir),
V1Constants.VALID_DOC_IDS_SNAPSHOT_FILE_NAME);
}
+ /**
+ * Can be overridden to perform operations after preload is done.
+ */
+ protected void onPreloadFinish() {
+ }
+
@Override
public boolean isPreloading() {
return _isPreloading;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
