You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by fr...@apache.org on 2025/02/22 10:21:45 UTC
(druid) branch master updated: mod to using ObjectReader (#17732)
This is an automated email from the ASF dual-hosted git repository.
frankchen pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new bab4bf80fc3 mod to using ObjectReader (#17732)
bab4bf80fc3 is described below
commit bab4bf80fc3f492c1c9f9ee4a53e0017ee07fffa
Author: umisan <t....@gmail.com>
AuthorDate: Sat Feb 22 19:21:39 2025 +0900
mod to using ObjectReader (#17732)
---
.../java/org/apache/druid/metadata/SqlSegmentsMetadataManager.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/druid/metadata/SqlSegmentsMetadataManager.java b/server/src/main/java/org/apache/druid/metadata/SqlSegmentsMetadataManager.java
index c38f7b87bf0..6cf7e21605a 100644
--- a/server/src/main/java/org/apache/druid/metadata/SqlSegmentsMetadataManager.java
+++ b/server/src/main/java/org/apache/druid/metadata/SqlSegmentsMetadataManager.java
@@ -20,6 +20,7 @@
package org.apache.druid.metadata;
import com.fasterxml.jackson.databind.ObjectMapper;
+import com.fasterxml.jackson.databind.ObjectReader;
import com.google.common.annotations.VisibleForTesting;
import com.google.common.base.Optional;
import com.google.common.base.Preconditions;
@@ -162,6 +163,7 @@ public class SqlSegmentsMetadataManager implements SegmentsMetadataManager
private final Object pollLock = new Object();
private final ObjectMapper jsonMapper;
+ private final ObjectReader segmentReader;
private final Duration periodicPollDelay;
private final Supplier<MetadataStorageTablesConfig> dbTables;
private final SQLMetadataConnector connector;
@@ -259,6 +261,7 @@ public class SqlSegmentsMetadataManager implements SegmentsMetadataManager
)
{
this.jsonMapper = jsonMapper;
+ this.segmentReader = jsonMapper.readerFor(DataSegment.class);
this.periodicPollDelay = config.get().getPollDuration().toStandardDuration();
this.dbTables = dbTables;
this.connector = connector;
@@ -1048,7 +1051,7 @@ public class SqlSegmentsMetadataManager implements SegmentsMetadataManager
.setFetchSize(connector.getStreamingFetchSize())
.map((index, r, ctx) -> {
try {
- DataSegment segment = jsonMapper.readValue(r.getBytes("payload"), DataSegment.class);
+ DataSegment segment = segmentReader.readValue(r.getBytes("payload"));
return replaceWithExistingSegmentIfPresent(segment);
}
catch (IOException e) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org