11package com .linkedin .venice .offsets ;
22
3+ import static com .linkedin .venice .guid .GuidUtils .guidToUtf8 ;
34import static com .linkedin .venice .pubsub .PubSubUtil .fromKafkaOffset ;
45
56import com .linkedin .venice .annotation .VisibleForTesting ;
67import com .linkedin .venice .exceptions .VeniceException ;
7- import com .linkedin .venice .guid .GuidUtils ;
88import com .linkedin .venice .kafka .protocol .GUID ;
99import com .linkedin .venice .kafka .protocol .state .IncrementalPushReplicaStatus ;
1010import com .linkedin .venice .kafka .protocol .state .PartitionState ;
@@ -202,11 +202,11 @@ public boolean isEndOfPushReceived() {
202202 }
203203
204204 public synchronized void setProducerPartitionState (GUID producerGuid , ProducerPartitionState state ) {
205- this .partitionState .producerStates .put (GuidUtils . guidToUtf8 (producerGuid ), state );
205+ this .partitionState .producerStates .put (guidToUtf8 (producerGuid ), state );
206206 }
207207
208208 public synchronized void removeProducerPartitionState (GUID producerGuid ) {
209- this .partitionState .producerStates .remove (GuidUtils . guidToUtf8 (producerGuid ));
209+ this .partitionState .producerStates .remove (guidToUtf8 (producerGuid ));
210210 }
211211
212212 public synchronized Map <CharSequence , ProducerPartitionState > getProducerPartitionStateMap () {
@@ -219,30 +219,30 @@ public synchronized void setRealtimeTopicProducerState(
219219 ProducerPartitionState state ) {
220220 partitionState .getRealtimeTopicProducerStates ()
221221 .computeIfAbsent (kafkaUrl , url -> new VeniceConcurrentHashMap <>())
222- .put (GuidUtils . guidToUtf8 (producerGuid ), state );
222+ .put (guidToUtf8 (producerGuid ), state );
223223 }
224224
225225 public synchronized void removeRealTimeTopicProducerState (String kafkaUrl , GUID producerGuid ) {
226226 if (partitionState .getRealtimeTopicProducerStates ().get (kafkaUrl ) == null ) {
227227 return ;
228228 }
229- partitionState .getRealtimeTopicProducerStates ().get (kafkaUrl ).remove (GuidUtils . guidToUtf8 (producerGuid ));
229+ partitionState .getRealtimeTopicProducerStates ().get (kafkaUrl ).remove (guidToUtf8 (producerGuid ));
230230 }
231231
232232 public synchronized ProducerPartitionState getRealTimeProducerState (String kafkaUrl , GUID producerGuid ) {
233233 Map <CharSequence , ProducerPartitionState > map = partitionState .getRealtimeTopicProducerStates ().get (kafkaUrl );
234234 if (map == null ) {
235235 return null ;
236236 }
237- return map .get (GuidUtils . guidToUtf8 (producerGuid ));
237+ return map .get (guidToUtf8 (producerGuid ));
238238 }
239239
240240 private Map <String , Map <CharSequence , ProducerPartitionState >> getRealTimeProducerState () {
241241 return partitionState .getRealtimeTopicProducerStates ();
242242 }
243243
244244 public synchronized ProducerPartitionState getProducerPartitionState (GUID producerGuid ) {
245- return getProducerPartitionStateMap ().get (GuidUtils . guidToUtf8 (producerGuid ));
245+ return getProducerPartitionStateMap ().get (guidToUtf8 (producerGuid ));
246246 }
247247
248248 public void setDatabaseInfo (Map <String , String > databaseInfo ) {
0 commit comments