Skip to content

Commit 27702a1

Browse files
nisargthakkarnisargthakkar
committed
[codestyle][all] Optimize imports - wildcard and unused
ACLOVERRIDE
1 parent f0ebb1b commit 27702a1

File tree

511 files changed

+3821
-936
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

511 files changed

+3821
-936
lines changed

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/DaVinciBackend.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package com.linkedin.davinci;
22

3-
import static com.linkedin.venice.ConfigKeys.*;
4-
import static java.lang.Thread.*;
3+
import static com.linkedin.venice.ConfigKeys.PUSH_STATUS_STORE_DERIVED_SCHEMA_ID;
4+
import static java.lang.Thread.currentThread;
55

66
import com.linkedin.davinci.compression.StorageEngineBackedCompressorFactory;
77
import com.linkedin.davinci.config.StoreBackendConfig;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/VersionBackend.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,8 @@
11
package com.linkedin.davinci;
22

3-
import static com.linkedin.venice.ConfigKeys.*;
3+
import static com.linkedin.venice.ConfigKeys.PUSH_STATUS_STORE_ENABLED;
4+
import static com.linkedin.venice.ConfigKeys.PUSH_STATUS_STORE_HEARTBEAT_INTERVAL_IN_SECONDS;
5+
import static com.linkedin.venice.ConfigKeys.SERVER_STOP_CONSUMPTION_WAIT_RETRIES_NUM;
46

57
import com.linkedin.davinci.config.VeniceStoreVersionConfig;
68
import com.linkedin.davinci.storage.chunking.AbstractAvroChunkingAdapter;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/client/AvroGenericDaVinciClient.java

+17-4
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,22 @@
11
package com.linkedin.davinci.client;
22

3-
import static com.linkedin.davinci.store.rocksdb.RocksDBServerConfig.*;
4-
import static com.linkedin.venice.ConfigKeys.*;
5-
import static com.linkedin.venice.client.store.ClientFactory.*;
6-
import static org.apache.avro.Schema.Type.*;
3+
import static com.linkedin.davinci.store.rocksdb.RocksDBServerConfig.ROCKSDB_LEVEL0_FILE_NUM_COMPACTION_TRIGGER;
4+
import static com.linkedin.davinci.store.rocksdb.RocksDBServerConfig.ROCKSDB_LEVEL0_FILE_NUM_COMPACTION_TRIGGER_WRITE_ONLY_VERSION;
5+
import static com.linkedin.davinci.store.rocksdb.RocksDBServerConfig.ROCKSDB_LEVEL0_SLOWDOWN_WRITES_TRIGGER;
6+
import static com.linkedin.davinci.store.rocksdb.RocksDBServerConfig.ROCKSDB_LEVEL0_SLOWDOWN_WRITES_TRIGGER_WRITE_ONLY_VERSION;
7+
import static com.linkedin.davinci.store.rocksdb.RocksDBServerConfig.ROCKSDB_LEVEL0_STOPS_WRITES_TRIGGER;
8+
import static com.linkedin.davinci.store.rocksdb.RocksDBServerConfig.ROCKSDB_LEVEL0_STOPS_WRITES_TRIGGER_WRITE_ONLY_VERSION;
9+
import static com.linkedin.davinci.store.rocksdb.RocksDBServerConfig.ROCKSDB_PLAIN_TABLE_FORMAT_ENABLED;
10+
import static com.linkedin.venice.ConfigKeys.CLUSTER_NAME;
11+
import static com.linkedin.venice.ConfigKeys.INGESTION_USE_DA_VINCI_CLIENT;
12+
import static com.linkedin.venice.ConfigKeys.KAFKA_ADMIN_CLASS;
13+
import static com.linkedin.venice.ConfigKeys.KAFKA_BOOTSTRAP_SERVERS;
14+
import static com.linkedin.venice.ConfigKeys.KAFKA_ZK_ADDRESS;
15+
import static com.linkedin.venice.ConfigKeys.SERVER_ENABLE_KAFKA_OPENSSL;
16+
import static com.linkedin.venice.ConfigKeys.ZOOKEEPER_ADDRESS;
17+
import static com.linkedin.venice.client.store.ClientFactory.getAndStartAvroClient;
18+
import static com.linkedin.venice.client.store.ClientFactory.getTransportClient;
19+
import static org.apache.avro.Schema.Type.RECORD;
720

821
import com.linkedin.avroutil1.compatibility.AvroCompatibilityHelper;
922
import com.linkedin.davinci.DaVinciBackend;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/compression/StorageEngineBackedCompressorFactory.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package com.linkedin.davinci.compression;
22

3-
import static com.linkedin.venice.compression.CompressionStrategy.*;
3+
import static com.linkedin.venice.compression.CompressionStrategy.ZSTD_WITH_DICT;
44

55
import com.linkedin.davinci.storage.StorageMetadataService;
66
import com.linkedin.venice.compression.CompressionStrategy;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/config/VeniceClusterConfig.java

+23-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,28 @@
11
package com.linkedin.davinci.config;
22

3-
import static com.linkedin.venice.ConfigKeys.*;
3+
import static com.linkedin.venice.ConfigKeys.CLUSTER_NAME;
4+
import static com.linkedin.venice.ConfigKeys.KAFKA_BOOTSTRAP_SERVERS;
5+
import static com.linkedin.venice.ConfigKeys.KAFKA_CLUSTER_MAP_KEY_NAME;
6+
import static com.linkedin.venice.ConfigKeys.KAFKA_CLUSTER_MAP_KEY_OTHER_URLS;
7+
import static com.linkedin.venice.ConfigKeys.KAFKA_CLUSTER_MAP_KEY_URL;
8+
import static com.linkedin.venice.ConfigKeys.KAFKA_CLUSTER_MAP_SECURITY_PROTOCOL;
9+
import static com.linkedin.venice.ConfigKeys.KAFKA_EMPTY_POLL_SLEEP_MS;
10+
import static com.linkedin.venice.ConfigKeys.KAFKA_FETCH_MAX_SIZE_PER_SEC;
11+
import static com.linkedin.venice.ConfigKeys.KAFKA_FETCH_MAX_WAIT_TIME_MS;
12+
import static com.linkedin.venice.ConfigKeys.KAFKA_FETCH_MIN_SIZE_PER_SEC;
13+
import static com.linkedin.venice.ConfigKeys.KAFKA_FETCH_PARTITION_MAX_SIZE_PER_SEC;
14+
import static com.linkedin.venice.ConfigKeys.KAFKA_FETCH_QUOTA_BYTES_PER_SECOND;
15+
import static com.linkedin.venice.ConfigKeys.KAFKA_FETCH_QUOTA_RECORDS_PER_SECOND;
16+
import static com.linkedin.venice.ConfigKeys.KAFKA_FETCH_QUOTA_TIME_WINDOW_MS;
17+
import static com.linkedin.venice.ConfigKeys.KAFKA_FETCH_QUOTA_UNORDERED_BYTES_PER_SECOND;
18+
import static com.linkedin.venice.ConfigKeys.KAFKA_FETCH_QUOTA_UNORDERED_RECORDS_PER_SECOND;
19+
import static com.linkedin.venice.ConfigKeys.KAFKA_READ_CYCLE_DELAY_MS;
20+
import static com.linkedin.venice.ConfigKeys.KAFKA_SECURITY_PROTOCOL;
21+
import static com.linkedin.venice.ConfigKeys.KAFKA_ZK_ADDRESS;
22+
import static com.linkedin.venice.ConfigKeys.PERSISTENCE_TYPE;
23+
import static com.linkedin.venice.ConfigKeys.REFRESH_ATTEMPTS_FOR_ZK_RECONNECT;
24+
import static com.linkedin.venice.ConfigKeys.REFRESH_INTERVAL_FOR_ZK_RECONNECT_MS;
25+
import static com.linkedin.venice.ConfigKeys.ZOOKEEPER_ADDRESS;
426

527
import com.linkedin.venice.SSLConfig;
628
import com.linkedin.venice.exceptions.ConfigurationException;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/config/VeniceServerConfig.java

+101-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,106 @@
11
package com.linkedin.davinci.config;
22

3-
import static com.linkedin.davinci.config.BlockingQueueType.*;
4-
import static com.linkedin.venice.ConfigKeys.*;
3+
import static com.linkedin.davinci.config.BlockingQueueType.ARRAY_BLOCKING_QUEUE;
4+
import static com.linkedin.venice.ConfigKeys.AUTOCREATE_DATA_PATH;
5+
import static com.linkedin.venice.ConfigKeys.AUTO_CLOSE_IDLE_CONSUMERS_ENABLED;
6+
import static com.linkedin.venice.ConfigKeys.DATA_BASE_PATH;
7+
import static com.linkedin.venice.ConfigKeys.ENABLE_SERVER_ALLOW_LIST;
8+
import static com.linkedin.venice.ConfigKeys.ENABLE_SERVER_WHITE_LIST;
9+
import static com.linkedin.venice.ConfigKeys.FREEZE_INGESTION_IF_READY_TO_SERVE_OR_LOCAL_DATA_EXISTS;
10+
import static com.linkedin.venice.ConfigKeys.HELIX_HYBRID_STORE_QUOTA_ENABLED;
11+
import static com.linkedin.venice.ConfigKeys.HYBRID_QUOTA_ENFORCEMENT_ENABLED;
12+
import static com.linkedin.venice.ConfigKeys.INGESTION_USE_DA_VINCI_CLIENT;
13+
import static com.linkedin.venice.ConfigKeys.KAFKA_ADMIN_CLASS;
14+
import static com.linkedin.venice.ConfigKeys.KAFKA_PRODUCER_METRICS;
15+
import static com.linkedin.venice.ConfigKeys.KAFKA_READ_ONLY_ADMIN_CLASS;
16+
import static com.linkedin.venice.ConfigKeys.KAFKA_WRITE_ONLY_ADMIN_CLASS;
17+
import static com.linkedin.venice.ConfigKeys.KEY_VALUE_PROFILING_ENABLED;
18+
import static com.linkedin.venice.ConfigKeys.LEADER_FOLLOWER_STATE_TRANSITION_THREAD_POOL_STRATEGY;
19+
import static com.linkedin.venice.ConfigKeys.LISTENER_PORT;
20+
import static com.linkedin.venice.ConfigKeys.MAX_FUTURE_VERSION_LEADER_FOLLOWER_STATE_TRANSITION_THREAD_NUMBER;
21+
import static com.linkedin.venice.ConfigKeys.MAX_LEADER_FOLLOWER_STATE_TRANSITION_THREAD_NUMBER;
22+
import static com.linkedin.venice.ConfigKeys.OFFSET_LAG_DELTA_RELAX_FACTOR_FOR_FAST_ONLINE_TRANSITION_IN_RESTART;
23+
import static com.linkedin.venice.ConfigKeys.PARTICIPANT_MESSAGE_CONSUMPTION_DELAY_MS;
24+
import static com.linkedin.venice.ConfigKeys.SERVER_AUTO_COMPACTION_FOR_SAMZA_REPROCESSING_JOB_ENABLED;
25+
import static com.linkedin.venice.ConfigKeys.SERVER_BLOCKING_QUEUE_TYPE;
26+
import static com.linkedin.venice.ConfigKeys.SERVER_CACHE_WARMING_BEFORE_READY_TO_SERVE_ENABLED;
27+
import static com.linkedin.venice.ConfigKeys.SERVER_CACHE_WARMING_STORE_LIST;
28+
import static com.linkedin.venice.ConfigKeys.SERVER_CACHE_WARMING_THREAD_POOL_SIZE;
29+
import static com.linkedin.venice.ConfigKeys.SERVER_COMPUTE_FAST_AVRO_ENABLED;
30+
import static com.linkedin.venice.ConfigKeys.SERVER_COMPUTE_QUEUE_CAPACITY;
31+
import static com.linkedin.venice.ConfigKeys.SERVER_COMPUTE_THREAD_NUM;
32+
import static com.linkedin.venice.ConfigKeys.SERVER_CONSUMER_POOL_SIZE_PER_KAFKA_CLUSTER;
33+
import static com.linkedin.venice.ConfigKeys.SERVER_DATABASE_CHECKSUM_VERIFICATION_ENABLED;
34+
import static com.linkedin.venice.ConfigKeys.SERVER_DATABASE_LOOKUP_QUEUE_CAPACITY;
35+
import static com.linkedin.venice.ConfigKeys.SERVER_DATABASE_MEMORY_STATS_ENABLED;
36+
import static com.linkedin.venice.ConfigKeys.SERVER_DATABASE_SYNC_BYTES_INTERNAL_FOR_DEFERRED_WRITE_MODE;
37+
import static com.linkedin.venice.ConfigKeys.SERVER_DATABASE_SYNC_BYTES_INTERNAL_FOR_TRANSACTIONAL_MODE;
38+
import static com.linkedin.venice.ConfigKeys.SERVER_DB_READ_ONLY_FOR_BATCH_ONLY_STORE_ENABLED;
39+
import static com.linkedin.venice.ConfigKeys.SERVER_DEBUG_LOGGING_ENABLED;
40+
import static com.linkedin.venice.ConfigKeys.SERVER_DEDICATED_DRAINER_FOR_SORTED_INPUT_ENABLED;
41+
import static com.linkedin.venice.ConfigKeys.SERVER_DELAY_REPORT_READY_TO_SERVE_MS;
42+
import static com.linkedin.venice.ConfigKeys.SERVER_DISK_FULL_THRESHOLD;
43+
import static com.linkedin.venice.ConfigKeys.SERVER_DISK_HEALTH_CHECK_INTERVAL_IN_SECONDS;
44+
import static com.linkedin.venice.ConfigKeys.SERVER_DISK_HEALTH_CHECK_SERVICE_ENABLED;
45+
import static com.linkedin.venice.ConfigKeys.SERVER_DISK_HEALTH_CHECK_TIMEOUT_IN_SECONDS;
46+
import static com.linkedin.venice.ConfigKeys.SERVER_ENABLE_KAFKA_OPENSSL;
47+
import static com.linkedin.venice.ConfigKeys.SERVER_ENABLE_LIVE_CONFIG_BASED_KAFKA_THROTTLING;
48+
import static com.linkedin.venice.ConfigKeys.SERVER_ENABLE_PARALLEL_BATCH_GET;
49+
import static com.linkedin.venice.ConfigKeys.SERVER_HTTP2_HEADER_TABLE_SIZE;
50+
import static com.linkedin.venice.ConfigKeys.SERVER_HTTP2_INBOUND_ENABLED;
51+
import static com.linkedin.venice.ConfigKeys.SERVER_HTTP2_INITIAL_WINDOW_SIZE;
52+
import static com.linkedin.venice.ConfigKeys.SERVER_HTTP2_MAX_CONCURRENT_STREAMS;
53+
import static com.linkedin.venice.ConfigKeys.SERVER_HTTP2_MAX_FRAME_SIZE;
54+
import static com.linkedin.venice.ConfigKeys.SERVER_HTTP2_MAX_HEADER_LIST_SIZE;
55+
import static com.linkedin.venice.ConfigKeys.SERVER_INGESTION_CHECKPOINT_DURING_GRACEFUL_SHUTDOWN_ENABLED;
56+
import static com.linkedin.venice.ConfigKeys.SERVER_INGESTION_ISOLATION_APPLICATION_PORT;
57+
import static com.linkedin.venice.ConfigKeys.SERVER_INGESTION_ISOLATION_SERVICE_PORT;
58+
import static com.linkedin.venice.ConfigKeys.SERVER_INGESTION_MODE;
59+
import static com.linkedin.venice.ConfigKeys.SERVER_KAFKA_CONSUMER_OFFSET_COLLECTION_ENABLED;
60+
import static com.linkedin.venice.ConfigKeys.SERVER_KAFKA_MAX_POLL_RECORDS;
61+
import static com.linkedin.venice.ConfigKeys.SERVER_KAFKA_POLL_RETRY_BACKOFF_MS;
62+
import static com.linkedin.venice.ConfigKeys.SERVER_KAFKA_POLL_RETRY_TIMES;
63+
import static com.linkedin.venice.ConfigKeys.SERVER_KAFKA_PRODUCER_POOL_SIZE_PER_KAFKA_CLUSTER;
64+
import static com.linkedin.venice.ConfigKeys.SERVER_LEAKED_RESOURCE_CLEANUP_ENABLED;
65+
import static com.linkedin.venice.ConfigKeys.SERVER_LEAKED_RESOURCE_CLEAN_UP_INTERVAL_IN_MINUTES;
66+
import static com.linkedin.venice.ConfigKeys.SERVER_LOCAL_CONSUMER_CONFIG_PREFIX;
67+
import static com.linkedin.venice.ConfigKeys.SERVER_MAX_REQUEST_SIZE;
68+
import static com.linkedin.venice.ConfigKeys.SERVER_NETTY_GRACEFUL_SHUTDOWN_PERIOD_SECONDS;
69+
import static com.linkedin.venice.ConfigKeys.SERVER_NETTY_IDLE_TIME_SECONDS;
70+
import static com.linkedin.venice.ConfigKeys.SERVER_NETTY_WORKER_THREADS;
71+
import static com.linkedin.venice.ConfigKeys.SERVER_NODE_CAPACITY_RCU;
72+
import static com.linkedin.venice.ConfigKeys.SERVER_NUM_SCHEMA_FAST_CLASS_WARMUP;
73+
import static com.linkedin.venice.ConfigKeys.SERVER_OPTIMIZE_DATABASE_FOR_BACKUP_VERSION_ENABLED;
74+
import static com.linkedin.venice.ConfigKeys.SERVER_OPTIMIZE_DATABASE_FOR_BACKUP_VERSION_NO_READ_THRESHOLD_SECONDS;
75+
import static com.linkedin.venice.ConfigKeys.SERVER_OPTIMIZE_DATABASE_SERVICE_SCHEDULE_INTERNAL_SECONDS;
76+
import static com.linkedin.venice.ConfigKeys.SERVER_PARALLEL_BATCH_GET_CHUNK_SIZE;
77+
import static com.linkedin.venice.ConfigKeys.SERVER_PARTITION_GRACEFUL_DROP_DELAY_IN_SECONDS;
78+
import static com.linkedin.venice.ConfigKeys.SERVER_PROMOTION_TO_LEADER_REPLICA_DELAY_SECONDS;
79+
import static com.linkedin.venice.ConfigKeys.SERVER_QUOTA_ENFORCEMENT_ENABLED;
80+
import static com.linkedin.venice.ConfigKeys.SERVER_REMOTE_CONSUMER_CONFIG_PREFIX;
81+
import static com.linkedin.venice.ConfigKeys.SERVER_REMOTE_INGESTION_REPAIR_SLEEP_INTERVAL_SECONDS;
82+
import static com.linkedin.venice.ConfigKeys.SERVER_REST_SERVICE_EPOLL_ENABLED;
83+
import static com.linkedin.venice.ConfigKeys.SERVER_REST_SERVICE_STORAGE_THREAD_NUM;
84+
import static com.linkedin.venice.ConfigKeys.SERVER_ROCKSDB_STORAGE_CONFIG_CHECK_ENABLED;
85+
import static com.linkedin.venice.ConfigKeys.SERVER_ROUTER_CONNECTION_WARMING_DELAY_MS;
86+
import static com.linkedin.venice.ConfigKeys.SERVER_SCHEMA_FAST_CLASS_WARMUP_TIMEOUT;
87+
import static com.linkedin.venice.ConfigKeys.SERVER_SCHEMA_PRESENCE_CHECK_ENABLED;
88+
import static com.linkedin.venice.ConfigKeys.SERVER_SHARED_CONSUMER_ASSIGNMENT_STRATEGY;
89+
import static com.linkedin.venice.ConfigKeys.SERVER_SHARED_CONSUMER_NON_EXISTING_TOPIC_CLEANUP_DELAY_MS;
90+
import static com.linkedin.venice.ConfigKeys.SERVER_SHARED_KAFKA_PRODUCER_ENABLED;
91+
import static com.linkedin.venice.ConfigKeys.SERVER_SHUTDOWN_DISK_UNHEALTHY_TIME_MS;
92+
import static com.linkedin.venice.ConfigKeys.SERVER_SOURCE_TOPIC_OFFSET_CHECK_INTERVAL_MS;
93+
import static com.linkedin.venice.ConfigKeys.SERVER_STORE_TO_EARLY_TERMINATION_THRESHOLD_MS_MAP;
94+
import static com.linkedin.venice.ConfigKeys.SERVER_SYSTEM_STORE_PROMOTION_TO_LEADER_REPLICA_DELAY_SECONDS;
95+
import static com.linkedin.venice.ConfigKeys.SERVER_UNSUB_AFTER_BATCHPUSH;
96+
import static com.linkedin.venice.ConfigKeys.SEVER_CALCULATE_QUOTA_USAGE_BASED_ON_PARTITIONS_ASSIGNMENT_ENABLED;
97+
import static com.linkedin.venice.ConfigKeys.SORTED_INPUT_DRAINER_SIZE;
98+
import static com.linkedin.venice.ConfigKeys.STORE_WRITER_BUFFER_MEMORY_CAPACITY;
99+
import static com.linkedin.venice.ConfigKeys.STORE_WRITER_BUFFER_NOTIFY_DELTA;
100+
import static com.linkedin.venice.ConfigKeys.STORE_WRITER_NUMBER;
101+
import static com.linkedin.venice.ConfigKeys.SYSTEM_SCHEMA_CLUSTER_NAME;
102+
import static com.linkedin.venice.ConfigKeys.UNREGISTER_METRIC_FOR_DELETED_STORE_ENABLED;
103+
import static com.linkedin.venice.ConfigKeys.UNSORTED_INPUT_DRAINER_SIZE;
5104

6105
import com.linkedin.davinci.helix.LeaderFollowerPartitionStateModelFactory;
7106
import com.linkedin.davinci.kafka.consumer.KafkaConsumerService;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/config/VeniceStoreVersionConfig.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package com.linkedin.davinci.config;
22

3-
import static com.linkedin.davinci.store.rocksdb.RocksDBServerConfig.*;
3+
import static com.linkedin.davinci.store.rocksdb.RocksDBServerConfig.ROCKSDB_PLAIN_TABLE_FORMAT_ENABLED;
44

55
import com.linkedin.venice.exceptions.ConfigurationException;
66
import com.linkedin.venice.exceptions.VeniceException;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/helix/HelixParticipationService.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package com.linkedin.davinci.helix;
22

3-
import static com.linkedin.venice.ConfigKeys.*;
3+
import static com.linkedin.venice.ConfigKeys.PUSH_STATUS_STORE_DERIVED_SCHEMA_ID;
44

55
import com.linkedin.davinci.config.VeniceConfigLoader;
66
import com.linkedin.davinci.config.VeniceServerConfig;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/helix/StateModelIngestionProgressNotifier.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package com.linkedin.davinci.helix;
22

3-
import static com.linkedin.davinci.helix.AbstractStateModelFactory.*;
3+
import static com.linkedin.davinci.helix.AbstractStateModelFactory.getStateModelID;
44

55
import com.linkedin.davinci.kafka.consumer.StoreIngestionService;
66
import com.linkedin.davinci.notifier.VeniceNotifier;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/ingestion/HttpClientTransport.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,7 @@
11
package com.linkedin.davinci.ingestion;
22

3-
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.*;
3+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.deserializeIngestionActionResponse;
4+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.serializeIngestionActionRequest;
45

56
import com.linkedin.venice.exceptions.VeniceException;
67
import com.linkedin.venice.exceptions.VeniceHttpException;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/ingestion/isolated/IsolatedIngestionNotifier.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
package com.linkedin.davinci.ingestion.isolated;
22

3-
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.*;
3+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.createIngestionTaskReport;
44

55
import com.linkedin.davinci.notifier.VeniceNotifier;
66
import com.linkedin.venice.ingestion.protocol.IngestionTaskReport;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/ingestion/isolated/IsolatedIngestionServer.java

+6-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,11 @@
11
package com.linkedin.davinci.ingestion.isolated;
22

3-
import static com.linkedin.venice.ConfigKeys.*;
4-
import static java.lang.Thread.*;
3+
import static com.linkedin.venice.ConfigKeys.D2_CLIENT_ZK_HOSTS_ADDRESS;
4+
import static com.linkedin.venice.ConfigKeys.SERVER_INGESTION_ISOLATION_HEARTBEAT_TIMEOUT_MS;
5+
import static com.linkedin.venice.ConfigKeys.SERVER_INGESTION_ISOLATION_STATS_CLASS_LIST;
6+
import static com.linkedin.venice.ConfigKeys.SERVER_REMOTE_INGESTION_REPAIR_SLEEP_INTERVAL_SECONDS;
7+
import static com.linkedin.venice.ConfigKeys.SERVER_STOP_CONSUMPTION_WAIT_RETRIES_NUM;
8+
import static java.lang.Thread.currentThread;
59

610
import com.linkedin.d2.balancer.D2Client;
711
import com.linkedin.d2.balancer.D2ClientBuilder;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/ingestion/isolated/IsolatedIngestionServerHandler.java

+6-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,11 @@
11
package com.linkedin.davinci.ingestion.isolated;
22

3-
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.*;
3+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.buildHttpResponse;
4+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.createIngestionTaskReport;
5+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.deserializeIngestionActionRequest;
6+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.getDummyContent;
7+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.readHttpRequestContent;
8+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.serializeIngestionActionResponse;
49

510
import com.linkedin.davinci.config.VeniceStoreVersionConfig;
611
import com.linkedin.davinci.ingestion.main.MainIngestionStorageMetadataService;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/ingestion/main/MainIngestionMonitorService.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
package com.linkedin.davinci.ingestion.main;
22

3-
import static com.linkedin.venice.ConfigKeys.*;
4-
import static java.lang.Thread.*;
3+
import static com.linkedin.venice.ConfigKeys.SERVER_INGESTION_ISOLATION_HEARTBEAT_TIMEOUT_MS;
4+
import static java.lang.Thread.currentThread;
55

66
import com.linkedin.davinci.config.VeniceConfigLoader;
77
import com.linkedin.davinci.ingestion.IsolatedIngestionBackend;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/ingestion/main/MainIngestionReportHandler.java

+4-1
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,9 @@
11
package com.linkedin.davinci.ingestion.main;
22

3-
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.*;
3+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.buildHttpResponse;
4+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.deserializeIngestionActionRequest;
5+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.getDummyContent;
6+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.readHttpRequestContent;
47

58
import com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils;
69
import com.linkedin.davinci.kafka.consumer.LeaderFollowerStateType;

‎clients/da-vinci-client/src/main/java/com/linkedin/davinci/ingestion/main/MainIngestionRequestClient.java

+4-2
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,9 @@
11
package com.linkedin.davinci.ingestion.main;
22

3-
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.*;
4-
import static com.linkedin.venice.ingestion.protocol.enums.IngestionCommandType.*;
3+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.buildAndSaveConfigsForForkedIngestionProcess;
4+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.getDummyCommand;
5+
import static com.linkedin.davinci.ingestion.utils.IsolatedIngestionUtils.saveForkedIngestionKafkaClusterMapConfig;
6+
import static com.linkedin.venice.ingestion.protocol.enums.IngestionCommandType.START_CONSUMPTION;
57

68
import com.linkedin.davinci.config.VeniceConfigLoader;
79
import com.linkedin.davinci.ingestion.HttpClientTransport;

0 commit comments

Comments
 (0)