From ffa96897d12666d36b7a233079da4b5c0b78a2c4 Mon Sep 17 00:00:00 2001 From: Ali Poursamadi Date: Tue, 12 Nov 2024 13:28:15 -0800 Subject: [PATCH] Explicit imports per venice coding style. --- .../VenicePubsubInputPartitionReaderTest.java | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/clients/venice-push-job/src/test/java/com/linkedin/venice/spark/input/pubsub/table/VenicePubsubInputPartitionReaderTest.java b/clients/venice-push-job/src/test/java/com/linkedin/venice/spark/input/pubsub/table/VenicePubsubInputPartitionReaderTest.java index 2627fed4e0c..f4608d3a07c 100644 --- a/clients/venice-push-job/src/test/java/com/linkedin/venice/spark/input/pubsub/table/VenicePubsubInputPartitionReaderTest.java +++ b/clients/venice-push-job/src/test/java/com/linkedin/venice/spark/input/pubsub/table/VenicePubsubInputPartitionReaderTest.java @@ -1,9 +1,15 @@ package com.linkedin.venice.spark.input.pubsub.table; -import static com.linkedin.venice.kafka.protocol.enums.MessageType.*; -import static com.linkedin.venice.vpj.VenicePushJobConstants.*; -import static org.mockito.Mockito.*; -import static org.testng.Assert.*; +import static com.linkedin.venice.kafka.protocol.enums.MessageType.PUT; +import static com.linkedin.venice.vpj.VenicePushJobConstants.KAFKA_INPUT_BROKER_URL; +import static com.linkedin.venice.vpj.VenicePushJobConstants.KAFKA_INPUT_TOPIC; +import static com.linkedin.venice.vpj.VenicePushJobConstants.KAFKA_SOURCE_KEY_SCHEMA_STRING_PROP; +import static org.mockito.Mockito.anyLong; +import static org.mockito.Mockito.mock; +import static org.mockito.Mockito.when; +import static org.testng.Assert.assertEquals; +import static org.testng.Assert.assertFalse; +import static org.testng.Assert.assertTrue; import com.linkedin.venice.kafka.protocol.GUID; import com.linkedin.venice.kafka.protocol.KafkaMessageEnvelope;