This is an automated email from the ASF dual-hosted git repository.
Jackie-Jiang 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 e6bd15e7d88 [Minor] Make Upsert/Dedup TTL_WATERMARK_NOT_SET public
accessible (#18865)
e6bd15e7d88 is described below
commit e6bd15e7d88a188b1bafcda7661a9ee563ab71fe
Author: Xiaotian (Jackie) Jiang <[email protected]>
AuthorDate: Mon Jun 29 10:44:42 2026 -0700
[Minor] Make Upsert/Dedup TTL_WATERMARK_NOT_SET public accessible (#18865)
---
.../pinot/segment/local/dedup/BasePartitionDedupMetadataManager.java | 3 ++-
.../segment/local/upsert/BasePartitionUpsertMetadataManager.java | 5 +++--
2 files changed, 5 insertions(+), 3 deletions(-)
diff --git
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/dedup/BasePartitionDedupMetadataManager.java
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/dedup/BasePartitionDedupMetadataManager.java
index b8fa0d6a649..b66da45d425 100644
---
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/dedup/BasePartitionDedupMetadataManager.java
+++
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/dedup/BasePartitionDedupMetadataManager.java
@@ -52,7 +52,8 @@ import org.slf4j.LoggerFactory;
public abstract class BasePartitionDedupMetadataManager implements
PartitionDedupMetadataManager {
// The special value to indicate the largest seen time is not set yet,
assuming times are positive.
- protected static final double TTL_WATERMARK_NOT_SET = 0;
+ public static final double TTL_WATERMARK_NOT_SET = 0;
+
protected final String _tableNameWithType;
protected final List<String> _primaryKeyColumns;
protected final int _partitionId;
diff --git
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/BasePartitionUpsertMetadataManager.java
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/BasePartitionUpsertMetadataManager.java
index bdc065d0e8d..733e4e24014 100644
---
a/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/BasePartitionUpsertMetadataManager.java
+++
b/pinot-segment-local/src/main/java/org/apache/pinot/segment/local/upsert/BasePartitionUpsertMetadataManager.java
@@ -75,9 +75,10 @@ import org.slf4j.LoggerFactory;
@ThreadSafe
public abstract class BasePartitionUpsertMetadataManager implements
PartitionUpsertMetadataManager {
- protected static final long OUT_OF_ORDER_EVENT_MIN_REPORT_INTERVAL_NS =
TimeUnit.MINUTES.toNanos(1);
// The special value to indicate the largest comparison value is not set
yet, and allow negative comparison values.
- protected static final double TTL_WATERMARK_NOT_SET =
Double.NEGATIVE_INFINITY;
+ public static final double TTL_WATERMARK_NOT_SET = Double.NEGATIVE_INFINITY;
+
+ protected static final long OUT_OF_ORDER_EVENT_MIN_REPORT_INTERVAL_NS =
TimeUnit.MINUTES.toNanos(1);
protected final String _tableNameWithType;
protected final TableType _tableType;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
