Skip to content

Commit

Permalink
Fixed spotbug issue
Browse files Browse the repository at this point in the history
  • Loading branch information
gaojieliu committed Oct 27, 2023
1 parent 9c23748 commit f4b8e90
Showing 1 changed file with 0 additions and 12 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@
import com.linkedin.venice.schema.rmd.RmdTimestampType;
import com.linkedin.venice.schema.rmd.RmdUtils;
import com.linkedin.venice.schema.writecompute.WriteComputeOperation;
import com.linkedin.venice.serializer.AvroGenericDeserializer;
import com.linkedin.venice.serializer.RecordDeserializer;
import com.linkedin.venice.serializer.RecordSerializer;
import com.linkedin.venice.utils.AvroSchemaUtils;
Expand Down Expand Up @@ -466,17 +465,6 @@ private GenericRecord convertRmdToUseReaderValueSchema(
return rmdSerde.deserializeRmdBytes(writerValueSchemaID, readerValueSchemaID, rmdBytes);
}

private GenericRecord deserializeValue(ByteBuffer bytes, Schema writerSchema, Schema readerSchema) {
/**
* TODO: Refactor this to use {@link com.linkedin.venice.serialization.StoreDeserializerCache}
*/
AvroGenericDeserializer<GenericRecord> deserializer = fastAvroEnabled
? MapOrderPreservingFastSerDeFactory.getDeserializer(writerSchema, readerSchema)
: MapOrderPreservingSerDeFactory.getDeserializer(writerSchema, readerSchema);

return deserializer.deserialize(bytes);
}

private boolean ignoreNewPut(
final int oldValueSchemaID,
GenericRecord oldValueFieldTimestampsRecord,
Expand Down

0 comments on commit f4b8e90

Please sign in to comment.