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 <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
